Hello,

I have a few questions that I couldn't find answers to in the documentation:


  *   Can added partitions be auto-discovered by kafka-streams? In my informal 
tests I have had to restart the stream nodes.
  *   Is it possible to rewind the consumer for a particular topic-partitions. 
e.g. if I have a Processor handling a topic-partition can I rewind that a to an 
arbitrary offset? I saw that kafka-streams-application-reset allows all 
partitions to be reset, but I'd like to decide per partition.

If anybody can shed any light on these issues I'd be most grateful.

Thanks.

Reply via email to