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

disableLogging() causes partitions to not be consumed

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Blocker
    • Resolution: Fixed
    • Affects Version/s: 0.11.0.1
    • Fix Version/s: 1.0.0
    • Component/s: streams
    • Labels:
      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

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

                Dates

                • Created:
                  Updated:
                  Resolved: