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

Root statestore is not registered with ProcessorStateManager, inner state store is registered instead

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.10.0.0
    • Fix Version/s: 0.10.0.0
    • Component/s: streams
    • Labels:
      None
    • Environment:
      MacOS El Capitan

      Description

      When the hierarchy of nested StateStores are created, init is called on the root store, but parent StateStores such as MeteredKeyValueStore just call the contained StateStore until a store such as MemoryStore calls ProcessorContext.register, but it passes 'this' to the method so only that inner state store (MemoryStore in this case) is registered with ProcessorStateManager. As state is added to the store none of the parent stores code will be called, metering, or even StoreChangeLogger to put the state on the kafka topic.

        Attachments

          Activity

            People

            • Assignee:
              tom_dearman Tom Dearman
              Reporter:
              tom_dearman Tom Dearman
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: