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)
