[jira] [Created] (KAFKA-8273) Admin client doesn't reestablish connection on Broker restart

["Christian Yotov (JIRA)" <ji...@apache.org>]

Christian Yotov created KAFKA-8273:
--------------------------------------

             Summary: Admin client doesn't reestablish connection on Broker restart
                 Key: KAFKA-8273
                 URL: https://issues.apache.org/jira/browse/KAFKA-8273
             Project: Kafka
          Issue Type: Bug
            Reporter: Christian Yotov


*Steps to reproduce:*
 # Setup Admin Client to use SSL connection
 # Execute Request against broker(i.e `describeTopics`)
 # Restart Kafka Broker
 # Execute Request against broker again

*Current Result:*

No request is being executed(tested with `tcpdump`) and timeout exception is being thrown.

Exception:
{code:java}
{"thread":"Kafka Liveness Thread","level":"ERROR","loggerName":"com.axway.hada.messaging.kafka.health.KafkaBaseHealthThread","message":"Failed to execute request on time against Kafka.","thrown":{"commonElementCount":0,"name":"java.util.concurrent.TimeoutException","extendedStackTrace":"java.util.concurrent.TimeoutException: null\n\tat org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:108) ~[kafka-clients-2.1.1.jar:?]\n\tat org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:274) ~[kafka-clients-2.1.1.jar:?]\n\tat com.axway.hada.messaging.kafka.health.KafkaBaseHealthThread.run(KafkaBaseHealthThread.java:47) [messaging-1.0.0.89d269c3.jar:?]\n"},"endOfBatch":false,"loggerFqcn":"org.apache.logging.slf4j.Log4jLogger","instant":{"epochSecond":1555939865,"nanoOfSecond":502000000},"threadId":31,"threadPriority":5} {"thread":"Kafka Liveness Thread","level":"DEBUG","loggerName":"org.apache.kafka.clients.admin.KafkaAdminClient","message":"[AdminClient clientId=adminclient-2] Queueing Call(callName=describeTopics, deadlineMs=1555939869502) with a timeout 2000 ms from now.","endOfBatch":false,"loggerFqcn":"org.apache.kafka.common.utils.LogContext$LocationAwareKafkaLogger","instant":{"epochSecond":1555939867,"nanoOfSecond":502000000},"threadId":31,"threadPriority":5}
{code}
*NOTE:* Issue cannot be reproduced with PLAINTEXT connection.

*Workaround:* If Admin client is recreated connection can be reestablished

 



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