카프카 스트림 - kafka-streams-application-reset.sh

Question

카프카 0.10.0.1이 kafka-streams-application-reset.sh

플루라는 스크립트를 사용하여 카프카 스트림 응용 프로그램을 재설정 할 수있는 기능을 추가 잘못된 API 버전을 보내는이 스크립트 here에 대한 몇 가지 좋은 문서를 가지고 .

불행하게도, 로컬 스크립트를 실행하면 오류가 발생합니다

$ 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 값을 기준으로 a meta data request 인 것으로 보입니다.

누군가가 왜 이런 일이 벌어지고 어떻게 해결 될 수 있는지 알려주세요.

Answer 1

카프카 스트림은 버전 0.10을 기반으로하며 0.9에서는 작동하지 않습니다.

bin/kafka-streams-application-reset 공구에 대해서도 마찬가지입니다. 내부적으로 0.10 KafkaClient을 사용하며 0.10 브로커가 필요합니다.

일반적으로 카프카 중개인 만 카프카 클라이언트가 아닌 하위 호환 가능합니다. 즉, 중개인은 이전 클라이언트에서 작동하지만 클라이언트는 오래된 중개인과 호환되지 않습니다. 향후 출시 될 때 개선 될 수 있습니다. KIP-97: Improved Kafka Client RPC Compatibility Policy

오류 메시지는 설명 적이 지 않고 이해하기 힘들지 만 새 클라이언트를 이해하지 못하는 브로커에 연결하려고한다는 메시지가 표시됩니다.