Unnecessary API version check for end_offsets
Aberta
- Linguagem predominante
- Python
- Estrelas
- 1.4k
- Forks
- 269
- Merge médio
- 1d 1h
- PRs com merge (30d)
- 6
Descrição
**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.
Guia de contribuição
Avaliação
Esta issue ainda não foi avaliada.