samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Alexander Taggart <>
Subject Controlling read offset
Date Mon, 10 Nov 2014 14:53:19 GMT
We're investigating using Samza, and one aspect of our usage would require
being able to start a job such that it begins reading from a specified
Kafka offset.  If I understand correctly, each job being bound to a
specific partition would need to be provided with a specific offset.  Is
there any facility for providing such values, either via config or via
API?  If not, what might be a good approach to implementing it (e.g., a
custom kafka consumer)?

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message