You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by GitBox <gi...@apache.org> on 2019/10/14 22:50:21 UTC

[GitHub] [samza] prateekm commented on issue #1187: SAMZA-2348 : Notifying BEM about kafkaConsumerProxy failure to prevent BEM poll-blockin in case of proxy failures

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:
users@infra.apache.org


With regards,
Apache Git Services