aio-libs / aio-libs/aiokafka

[QUESTION] Support for Apache Kafka 4.0

オープン
#1,085 コメント 14 件 リアクション 6 件 担当者 0 名 GitHub で見る
question
主要言語
Python
スター
1.4k
フォーク
269
平均マージ
1日 1時間
マージ済み PR(30日)
6

説明

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).

コントリビューションガイド

コントリビューションガイドを開く

評価

この issue はまだ評価されていません。

新しい issue をメールで受け取る

初心者向けの GitHub issue を短くまとめたダイジェスト。