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)?
- Controlling read offset Alexander Taggart
- Re: Controlling read offset Chris Riccomini
- Re: Controlling read offset Alexander Taggart
- Re: Controlling read offset Chris Riccomini
