Bruno Cadonna created KAFKA-10119:
-------------------------------------
Summary: StreamsResetter fails with TimeoutException for older
Brokers
Key: KAFKA-10119
URL: https://issues.apache.org/jira/browse/KAFKA-10119
Project: Kafka
Issue Type: Bug
Components: consumer
Affects Versions: 2.6.0
Reporter: Bruno Cadonna
Since somewhere after commit 2d37c8c84 in Apache Kafka, the streams resetter
consistently fails with brokers of version confluent-5.0.1.
The following exception is thrown:
{code:java}
org.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms expired
before the position for partition test-0 could be determined
{code}
which comes from this line within the {{StreamsResetter}} class:
{code:java}
System.out.println("Topic: " + p.topic() + " Partition: " + p.partition() + "
Offset: " + client.position(p));
{code}
The exception is not thrown with brokers of version confluent-5.5.0. I have not
tried brokers of other versions.
The bug can be reproduced with the following steps:
1. check out commit 7777dc8f8ffd2ad from Apache Kafka
2. build with {{./gradlew clean -PscalaVersion=2.13 jar}}
3. start a confluent-5.0.1 broker.
4. create a topic with {{bin/kafka-topics.sh --create --bootstrap-server
localhost:9092 --replication-factor 1 --partitions 1 --topic test}}
5. start streams resetter with {{bin/kafka-streams-application-reset.sh
--application-id test --bootstrap-servers localhost:9092 --input-topics test}}
Streams resetter should output:
{code}
ERROR: org.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms
expired before the position for partition test-0 could be determined
org.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms expired
before the position for partition test-0 could be determined
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
