kafka stream processor api Global state store multiple topics

Question

I am trying to create a kafka stream using processor api as i have custom process. I faced an issue when my processor was listning to multiple topics with different number of partitions. I realized i need to create a global state store. I need to know how to be able to add a processor and also add a global state store while that listens to multiple topics?

Any code examples or links will help. Thank You!!

Answer 1

A global state store can only read from a single topic. But you can create one global store per topic. Also, global stores don't need to be added to any processor and can be access by all processor automatically.

Our examples repo should help: https://github.com/confluentinc/kafka-streams-examples

Also check out the docs: http://docs.confluent.io/current