huxihx commented on KAFKA-6446:

Sounds like it's easy to replace await() with the timed version. However,  
there is another serious problem in this case in which Sender thread got stuck 
in the infinite loop in `maybeSendTransactionalRequest` which impedes the 
thread to be closed. [~becket_qin] Does it make sense?

> KafkaProducer with transactionId endless waits when bootstrap server is down
> ----------------------------------------------------------------------------
>                 Key: KAFKA-6446
>                 URL: https://issues.apache.org/jira/browse/KAFKA-6446
>             Project: Kafka
>          Issue Type: Bug
>          Components: clients, producer 
>    Affects Versions:, 1.0.0
>            Reporter: Eduardo Sciullo
>            Priority: Critical
>         Attachments: Test.java
> When bootstrap server is down, a KafkaProducer with transactionId endless 
> waits on initTransactions. 
> The timeouts don't apply to that operation: don't honor the 
> Attached an example of my code to reproduce the scenario.
> I opened this issue as suggested by [Gary 
> Russell|https://stackoverflow.com/users/1240763/gary-russell]
> [https://stackoverflow.com/questions/48226546/defaultkafkaproducerfactory-with-transactionidprefix-endless-waits-when-bootstra]

This message was sent by Atlassian JIRA

Reply via email to