Search code examples
apache-kafkaapache-kafka-streams

number of partitions for global state store in kafka streams

Is global state store in kafka always one partition or we can have multiple partitions for global state store changelog topic?

I am not able to find any clear documentation around this.

Solution

  • Like Matthias J. Sax has written here:

    A global store is a read-only materialized view of the data from the corresponding input topic

    So it is not like standard Kafka Streams changelog topics. Number of partitions is up to the topic creator and Kafka Broker limitation.

    Summarizing it doesn't have to be one partition and can be more.