Kafka Streams - kafka-streams-application-reset.sh sending wrong API version
NickName:foxygen Ask DateTime:2016-12-01T09:37:07

Kafka Streams - kafka-streams-application-reset.sh sending wrong API version

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?

Copyright Notice:Content Author:「foxygen」,Reproduced under the CC 4.0 BY-SA copyright license with a link to the original source and this disclaimer.
Link to original article:https://stackoverflow.com/questions/40901222/kafka-streams-kafka-streams-application-reset-sh-sending-wrong-api-version

More about “Kafka Streams - kafka-streams-application-reset.sh sending wrong API version” related questions

Kafka Streams - kafka-streams-application-reset.sh sending wrong API version

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, run...

Show Detail

How to reset kafka streams application using the java code?

I want to remove all intermediate topics and reprocess data. On the development time I'm doing restart with this command; docker exec -i containerName kafka-streams-application-reset.sh --bootstrap-

Show Detail

kafka-streams-scala version vis-à-vis kafka-streams version

Should the version of org.apache.kafka/kafka-streams-scala that I use in a project, be identical to the org.apache.kafka/kafka-streams version? Or can I, for example, use kafka-streams-scala vers...

Show Detail

Kafka sending Streams

hello i want to send a message from producer and received in consumer as capitalized. using CONFLUENT and KAFKA with a build.gradle file and StreamingApp.java containing this codes: ProcessingApp....

Show Detail

Why doesn't bin/kafka-streams-application-reset.sh resetting my application?

Matthias, thanks for the information about kafka-streams-application-reset.sh, but it does not appear that it has the effect of resetting the state of the world (for a particular Application ID) to...

Show Detail

Kafka stream application not consume data after restart

After I did restart our Kafka cluster my application of Kafka streams didn't receive messages from input topic and I got an exception of "can׳t create internal topic". After some research, I did re...

Show Detail

Kafka Streams client library compatibility with kafka broker version

I am using kafka client & streams library version 2.7.0 for building my application. However the kafka brokers(2 different clusters) are at older version ( 2.4.1 & 2.6.0). As i understand w...

Show Detail

Can a Kafka Streams StateStore be used outwith the Kafka Streams API?

I'm writing an application that uses the Kafka Producer API to publish messages. My code has some key value metadata that I need to store in a fault tolerant manner. I could implement this myself...

Show Detail

Kafka Streams DSL over Kafka Consumer API

Recently, in an interview, I was asked a questions about Kafka Streams, more specifically, interviewer wanted to know why/when would you use Kafka Streams DSL over plain Kafka Consumer API to read ...

Show Detail

Node disconnected errors in Kafka Streams API

I have creates Kafka Consumer code using Kafka Streams API and I'm able to fetch the records from Kafka Topic successfully and able to process those. I'm seeing below error in the application logs ...

Show Detail