Kafka Streams internal repartitioning topics, retention time, and reprocessing old data

2017-07-24 Thread Gerd Behrmann
Hi, While adding a new Streams based micro service to an existing Kafka infrastructure, I have run into some issues processing older data in existing topics. I am uncertain of the exact cause of the problems, but am looking for advice to clarify how things are supposed to work to eliminate poss

Kafka Streams internal repartitioning topics, retention time, and reprocessing old data

2017-07-27 Thread Gerd Behrmann
Hi, While adding a new Streams based micro service to an existing Kafka infrastructure, I have run into some issues processing older data in existing topics. I am uncertain of the exact cause of the problems, but am looking for advice to clarify how things are supposed to work to eliminate poss