When connection is not established and try to close producer connection, there is block for around 1min. This is because Promise<Void> trampolineProm = ctx.promise(); is executing in io.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl.close(long):272. I see that on the master branch this line was changed around 1 year ago: https://github.com/vert-x3/vertx-kafka-client/commit/a0e349fca33d3bb4f003ac53e6e0def42a76e8ab and I'm wondering why this wasn't part of release.
Can you add this change to next release or provide better solution? Currently I call unwrap() and then close connection natively.
Version
4.5.7
Steps to reproduce
Start producer connection with some dummy url
Stop producer.
Logs [Producer clientId=producer-5] Connection to node -1 (localhost/127.0.0.1:1111) could not be established. Broker may not be available. appears for around 1 min and then connection is correctly closed.
Questions
When connection is not established and try to close producer connection, there is block for around 1min. This is because
Promise<Void> trampolineProm = ctx.promise();is executing inio.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl.close(long):272. I see that on the master branch this line was changed around 1 year ago: https://github.com/vert-x3/vertx-kafka-client/commit/a0e349fca33d3bb4f003ac53e6e0def42a76e8ab and I'm wondering why this wasn't part of release.Can you add this change to next release or provide better solution? Currently I call unwrap() and then close connection natively.
Version
4.5.7
Steps to reproduce
[Producer clientId=producer-5] Connection to node -1 (localhost/127.0.0.1:1111) could not be established. Broker may not be available.appears for around 1 min and then connection is correctly closed.