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

["John Roesler (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128608#comment-17128608 ] 

John Roesler commented on KAFKA-10119:
--------------------------------------

Thanks for marking this as a blocker, it seems like a regression.

> 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)