Hello Maria,
We have some thoughts about supporting finer grained flow controls in Kafka
Streams https://issues.apache.org/jira/browse/KAFKA-3478 as part of a big
effort to improve re-processing user experience, which covers this use
case. We are shooting to have this post 0.10.0.0.
As for now, o
Kafka Streams look great, but there is one thing I don't seem to find a way
to do:
- read a topic from beginning even if there is a offset saved:
I have :
props.put(StreamsConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
this works as described if there is no offset s