g1geordie commented on pull request #9707: URL: https://github.com/apache/kafka/pull/9707#issuecomment-747188758
@ijuma hello The close method want to prevent self-join but there are no deadlock . The flush method in callback has a deadlock. The deadlock is because `flush` wait the `sender` send all message . but messages are done after callback complete . **flush in callback , callback will never complete .** `flush`'s semanteme is send message . so wait all message send I think it's necessary . Messages are done after callback I think is option , Or we can make async to `callback` ,then messages will done no matter `callback` is complete. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
