Looking through the documentation, it seems that KafkaSpout does not expose any way to set the offset the spout reads from after the initial poll. This functionality is supported in KafkaConsumer through the seek() method. Am I correct that this isn't supported? Has anyone found a way to mimic the behavior of seek() with KafkaSpout?
- Seek in KafkaSpout Mitchell Rathbun (BLOOMBERG/ 731 LEX)
- Re: Seek in KafkaSpout Stephen Powis
- Re: Seek in KafkaSpout Mitchell Rathbun (BLOOMBERG/ 731 LEX)
- Re: Seek in KafkaSpout Stephen Powis