Closed jhickson closed 6 years ago
This exception is Java-only and is raised if one of the following error codes occurs:
UNKNOWN_MEMBER_ID
ILLEGAL_GENERATION
REBALANCE_IN_PROGRESS
(See this).
So, the code here needs changing to detect one of these error codes (available from KafkaException).
KafkaException
The codes that Python will see are here.
This exception is Java-only and is raised if one of the following error codes occurs:
UNKNOWN_MEMBER_IDILLEGAL_GENERATIONREBALANCE_IN_PROGRESS(See this).
So, the code here needs changing to detect one of these error codes (available from
KafkaException).The codes that Python will see are here.