Skip to content

Tags: ArmisSecurity/kafka-python

Tags

2.0.2.post0

Toggle 2.0.2.post0's commit message
increment version to 2.0.2.post0

2.0.2-OffsetFetchRequest_v3

Toggle 2.0.2-OffsetFetchRequest_v3's commit message
Use OffsetFetchRequest_v3 in _send_offset_fetch_request

Due to a bug in kafka, empty response can return instead of an error for OffsetFetchRequest_v1, since v1 does not support top-level errors.
This issue resulted in an incident where the consumer interpret the bad response as "the consumer group does not have offsets for the topic partition", and therefore it reset the offsets according to the auto-reset-policy which was set to earliest.

In order to avoid the problem, this fix makes sure to use v3, and to check for top-level errors in the response.

2.0.2

Toggle 2.0.2's commit message
Patch Release 2.0.2