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

Christian Yotov updated KAFKA-8273:
-----------------------------------
    Description: 
*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":"DEBUG","loggerName":"org.apache.kafka.clients.admin.KafkaAdminClient","message":"[AdminClient
 clientId=adminclient-2] Queueing Call(callName=describeTopics, 
deadlineMs=1555939865501) with a timeout 2000 ms from 
now.","endOfBatch":false,"loggerFqcn":"org.apache.kafka.common.utils.LogContext$LocationAwareKafkaLogger","instant":{"epochSecond":1555939863,"nanoOfSecond":501000000},"threadId":31,"threadPriority":5}
{"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}
{code}
*NOTE:* Issue cannot be reproduced with PLAINTEXT connection.

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

 

  was:
*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

 


> 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
>            Priority: Major
>
> *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":"DEBUG","loggerName":"org.apache.kafka.clients.admin.KafkaAdminClient","message":"[AdminClient
>  clientId=adminclient-2] Queueing Call(callName=describeTopics, 
> deadlineMs=1555939865501) with a timeout 2000 ms from 
> now.","endOfBatch":false,"loggerFqcn":"org.apache.kafka.common.utils.LogContext$LocationAwareKafkaLogger","instant":{"epochSecond":1555939863,"nanoOfSecond":501000000},"threadId":31,"threadPriority":5}
> {"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}
> {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)

Reply via email to