[GitHub] [beam] johnjcasey commented on issue #25962: [Bug]: Java SDF-based Kafka ingestion can be stuck at certain offsets in certain conditions

["johnjcasey (via GitHub)" <gi...@apache.org>]

johnjcasey commented on issue #25962:
URL: https://github.com/apache/beam/issues/25962#issuecomment-1497921558

   Thank you for this. I agree this is a breaking change.
   
   I'd rather not do a failfast. I think 2 or 3 are the least intrusive, as we can then remove it when there is a fix in kafka. I prefer 2, but I'm also not sure about the gaurentees provided by consumer.position()


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org