[
https://issues.apache.org/jira/browse/KAFKA-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-10119:
----------------------------------
Priority: Blocker (was: Major)
> 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
> Priority: Blocker
>
> 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)
