storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Mitchell Rathbun (BLOOMBERG/ 731 LEX)" <>
Subject Seek in KafkaSpout
Date Thu, 28 Sep 2017 23:06:06 GMT
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?
View raw message