[jira] [Resolved] (KAFKA-10119) StreamsResetter fails with TimeoutException for older Brokers

["Sophie Blee-Goldman (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Sophie Blee-Goldman resolved KAFKA-10119.
-----------------------------------------
    Resolution: Duplicate

Closing this as a duplicate, the issue is tracked by KAFKA-10123

> 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, 2.5.1
>            Reporter: Bruno Cadonna
>            Priority: Blocker
>             Fix For: 2.6.0, 2.5.1
>
>
> 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)