KafkaConsumer 0.10.0で0.9.0のメッセージを読む？

Question

バージョン0.10.0のKafkaConsumerの0.9.0ブローカからメッセージを読むことはできますか？

ドキュメントの読み方ブローカーを0.9から0.10にアップグレードする方法については、既存のログを扱う方法で説明しています。ブローカーは、0.9のメッセージを古い消費者に送信するように指示することさえできます。

しかし、私は他の方法のラウンドを探しています：新しい消費者、古いブローカー。

しようNaivly、私は例外を取得：

org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'topic_metadata': Error reading array of size 1142898, only 2701 bytes available 

は、古いスタイルのメッセージを期待する0.10.0消費者に伝える方法はありますか？

Answer 1

私はカフカ・ジラで同様の問題を開き、かなり曖昧さのない回答を得ています。ブローカをまずアップグレードしてからクライアントをアップグレードしてください。これにより、要求を処理するために必要なすべての機能が実装され、ブローカーが正常に処理できるようになります。

詳細に興味がある場合は、私が開いた問題のリンクを示します。https://issues.apache.org/jira/browse/KAFKA-2496です。