0

Spark ストリーミングは 0.8.2.1 より上のバージョンの kafka と互換性がありますか? カスタム レシーバーを作成するのは、spark ストリーミングで 0.9 より上のバージョンの kafka を使用する唯一のオプションですか?

4

1 に答える 1

0

server.properties ファイルに「inter.broker.protocol.version=CURRENT_KAFKA_VERSION (eg 0.8.2 or 0.9.0.0)」を追加しました。これにより、古い 0.8.2.1 コンシューマーが新しいバージョンの kafka ブローカーからデータを受信できるようになります。

于 2016-06-03T22:56:13.677 に答える