[SAMZA-2348] Notifying BEM about kafkaConsumerProxy failure via kafkaConsumer to prevent BEM poll blocking in case of proxy failures

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Fix Version/s: 1.3
• Assignee: Unassigned
• Reporter: Rayman
• Created: 14/Oct/19 21:57
• Updated: 07/Nov/19 00:05

Description

The problem is that a container's startup blocks indefinitely during Changelog / Checkpoint / Coordinator stream read, 
whenever the KafkaConsumerProxy fails for some reason (e.g., TopicAuth).

This is because the SSPIterator keeps blocking on the blocking poll even when KafkaConsumerProxy stops due to exceptions thrown from KafkaConsumer.

The fix is to allow KafkaConsumerProxy to report exceptions to KafkaSystemConsumer, which then relays it to BEM.
BEM checks if there are any exceptions when doing a poll and re-throws.

Issue Links

• links to: GitHub Pull Request #1187