kafkaの異なるクライアントバージョンがKafkaブローカーの単一バージョンをヒットできますか？私は、新しいバージョンのKafkaが古いバージョンのクライアントを受け入れるために、 'inter.broker.protocol.version'を有効にできることを知っています。異なるバージョンのクライアント、Kafkaブローカーの単一バージョンで
たとえば、Kafkaクライアントの0.8と0.9の両方のバージョンを0.9 Kafkaブローカーで動作させる方法はありますか。 inter.broker.protocol.versionはこれに何らかの関係を持っていない
は実際には、その唯一の目的は、あなたがinter.broker.protocol.versionを設定する理由ですので、新しいブローカーが古いブローカーが理解できない、新しいプロトコルのバージョンを「話し」開始事態を防ぐために、クラスタのローリング・アップグレードをサポートすることです現在のクラスタバージョンに変更します。
クライアントに関しては、1つの単純なルールが満たされている限り、何の問題もないはずです。クライアントはブローカーによってサポートされているプロトコルバージョンを使用する必要があります。 0.9ブローカは古いクライアントからのすべての要求をうまく処理しますが、0.10に登場した要求バージョンでは失敗します。基本的にルールはupgrade brokers first, then clientsであり、クライアントの要求をうまく処理するためにブローカに必要なすべてのロジックが実装されていることを確認します。
クライアントは要求ごとに要求バージョンを送信するため、ブローカーは古いクライアントを新しいものと区別して要求を適切に処理できます。