On 03/10/2015 05:48 PM, Mayuresh Gharat wrote: > How do you typically handle workers starting, always start at offset 0 > to make sure the view is correctly recreated ? > ---> You will have to reset the offsets to 0 and the offset reset policy to > earliest in consumer.
Yup, as expected. > > How do you handle topology changes in consumers, which lead to a > redistribution of key across them ? > ---> Can you explain what exactly do you want to handle here? > This is a non-issue, sorry about that. > Is there a valid mechanism to know the log is being reconsumed and to > let the client layer know of this ? > ---> I suppose you will have to maintain this in your application by > checking keeping track of offset that was consumed in the past and the > offset currently being consumed. Thanks Mayuresh! - pyr