3

Kafka 0.10.0.1 adds the ability to reset a Kafka Streams app using a script called kafka-streams-application-reset.sh

Confluent has some good documentation on this script here.

Unfortunately, running the script locally results in an error:

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

Also, the following line appears in the broker logs:

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

From what I can tell, it looks like the client is making an invalid request, but I'm unsure why this happening. Our brokers are still on 0.9.0 so I'm not sure if that's the issue, but it appears to be a meta data request based on the apiKey value in the broker log.

Could someone please let me know why this might be happening and how it can be resolved?

4

1 回答 1

1

Kafka Streams 基于 0.10 版本，不适用于 0.9。

bin/kafka-streams-application-reset工具也是如此。它在内部使用 0.10KafkaClient并且需要 0.10 代理。

一般来说，只有 Kafka 代理而不是 Kafka 客户端是向后兼容的，即代理确实与旧客户端合作，但客户端不与旧代理合作。这可能会在将来发布时有所改善。请参阅KIP-97：改进的 Kafka 客户端 RPC 兼容性策略

错误消息——即使不是非常具有描述性且难以理解——也在告诉您您尝试连接到不了解新客户端的代理。

于 2016-12-01T05:12:03.613 回答