Global State Restore Listener

Hi All, I have a global state and the same in a local cache. Whenever there is an update to state I'm updating the local cache as well so that they are consistent. But when the state gets restored the cache is empty. Is there a way to attach a callback function or some way to get the state data du

increase in latency with increase in number of partitions per broker

Hi, I am trying to measure throughput of my 3 broker kafka cluster. I have created a topic with 3 partitions spread equally over the 3 brokers. Run a producer application to produce messages. producer application has 3 thread (one for each partition) to produce. Then i increased the number of parti