Unnecessary API version check for end_offsets
Ouverte
- Langage dominant
- Python
- Étoiles
- 1.4k
- Forks
- 269
- Merge moyen
- 1 j 1 h
- PR mergées (30 j)
- 6
Description
**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.
Guide de contribution
Ouvrir le guide de contribution
Évaluation
Cette issue n'a pas encore été évaluée.