apache-kafka - Kafka ストリーム - kafka-streams-application-reset.sh が間違った API バージョンを送信する

Question

Kafka 0.10.0.1 は、kafka-streams-application-reset.sh というスクリプトを使用して Kafka Streams アプリをリセットする機能を追加します

Confluent には、このスクリプトに関する適切なドキュメントがいくつかあります。

残念ながら、スクリプトをローカルで実行するとエラーが発生します。

$ bin/kafka-streams-application-reset --application-id my-streams-app \
                                      --input-topics my-input-topic \
                                      --intermediate-topics rekeyed-topic \
                                      --bootstrap-servers brokerHost:9092 \
                                      --zookeeper zookeeperHost:2181

# output
ERROR: Request GROUP_COORDINATOR failed on brokers List(...)

また、次の行がブローカー ログに表示されます。

kafka.network.InvalidRequestException: Error getting request for apiKey: 3 and apiVersion: 2

私が知る限り、クライアントが無効なリクエストを行っているように見えますが、なぜそうなったのかはわかりません。当社のブローカーはまだ 0.9.0 を使用しているため、それが問題かどうかはわかりませんが、ブローカー ログの値に基づくメタ データ リクエストのようです。apiKey

誰かがなぜこれが起こっているのか、どうすれば解決できるのか教えてもらえますか?