aiokafka icon indicating copy to clipboard operation
aiokafka copied to clipboard

Unnecessary API version check for end_offsets

Open KPull opened this issue 4 years ago • 0 comments
trafficstars

Describe the bug The consumer end_offsets() function checks the minimum Kafka API version is 0.10.0 claiming that "offsets_for_times API not supported". However, this is neither the "offsets_for_times API" and the function works without the if-statement at https://github.com/aio-libs/aiokafka/blob/master/aiokafka/consumer/consumer.py#L984-L987.

Expected behaviour The function should work even without setting the API version.

KPull avatar Mar 30 '21 13:03 KPull