[QUESTION] Support for Apache Kafka 4.0
Aberta
question
- Linguagem predominante
- Python
- Estrelas
- 1.4k
- Forks
- 269
- Merge médio
- 1d 1h
- PRs com merge (30d)
- 6
Descrição
Hi,
Apache Kafka 4.0 is removing a number of very old protocol api versions via [KIP-896](https://cwiki.apache.org/confluence/display/KAFKA/KIP-896%3A+Remove+old+client+protocol+API+versions+in+Kafka+4.0).
When I was looking at the code, I noticed that we seem to use V0 or V1 below:
https://github.com/ulrikjohansson/aiokafka/blob/master/aiokafka/client.py#L179
Am I reading that right? If so, this will not work with Apache Kafka 4.0 and would have to change to use at least
Metadata request v4 (but ideally it would just use the newest version supported by the broker).
Guia de contribuição
Avaliação
Esta issue ainda não foi avaliada.