prateekm commented on issue #1187: SAMZA-2348 : Notifying BEM about kafkaConsumerProxy failure to prevent BEM poll-blockin in case of proxy failures URL: https://github.com/apache/samza/pull/1187#issuecomment-541964344 Code looks good top me. Can you clarify the JIRA / commit description to explain the symptoms we saw (Container startup blocks indefinitely during Changelog / Checkpoint / Coordinator stream read), the cause: (SSPIterator keeps blocking on the blocking poll even when KafkaConsumerProxy stops due to exceptions thrown from KafkaConsumer), and the fix (KafkaConsumerProxy reports exceptions to KafkaSystemConsumer, which then reports it to BEM. BEM checks if there are any exceptions when doing a poll and re-throws.
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
