Jason Gustafson created KAFKA-7369:
--------------------------------------

             Summary: Retry when possible in AdminClient.listConsumerGroups
                 Key: KAFKA-7369
                 URL: https://issues.apache.org/jira/browse/KAFKA-7369
             Project: Kafka
          Issue Type: Bug
            Reporter: Jason Gustafson
            Assignee: Jason Gustafson


Currently we do not retry ListGroups requests when they fail due to retriable 
errors. For example, this is causing some instability in 
`kafka.admin.ListConsumerGroupTest.testListConsumerGroups`.

{code}
java.util.concurrent.ExecutionException: 
org.apache.kafka.common.errors.CoordinatorLoadInProgressException: Error 
listing groups on localhost:43001 (id: 0 rack: null)
        at 
org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
        at 
org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
        at 
org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89)
        at 
org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:262)
        at 
kafka.admin.ConsumerGroupCommand$ConsumerGroupService.listGroups(ConsumerGroupCommand.scala:132)
{code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to