Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-5989

disableLogging() causes partitions to not be consumed

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Blocker
    • Resolution: Fixed
    • 0.11.0.1
    • 1.0.0
    • streams
    • None

    Description

      Using disableLogging() for either of the built-in state store types causes an initialization loop in the StreamThread.

      Case A - this works just fine:

      		final StateStoreSupplier testStore = Stores.create(topic)
      				.withStringKeys()
      				.withStringValues()
      				.inMemory()
      //				.disableLogging() 
      				.maxEntries(10)
      				.build();
      

      Case B - this does not:

      		final StateStoreSupplier testStore = Stores.create(topic)
      				.withStringKeys()
      				.withStringValues()
      				.inMemory()
      				.disableLogging() 
      				.maxEntries(10)
      				.build();
      

      A brief debugging dive shows that in Case B, AssignedTasks.allTasksRunning() never returns true, because of a remnant entry in AssignedTasks#restoring that never gets properly restored.

      See App.java for a working test (requires ZK + Kafka ensemble, and at least one keyed message produced to the "test" topic)

      Attachments

        1. App2.java
          4 kB
          Tuan Nguyen
        2. App.java
          3 kB
          Tuan Nguyen

        Issue Links

          Activity

            People

              damianguy Damian Guy
              thn929 Tuan Nguyen
              Guozhang Wang Guozhang Wang
              Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: