aiokafka
aiokafka copied to clipboard
Unnecessary API version check for end_offsets
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.