Long producer closing when connection is not estabilished

[podlesrafal]

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 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

1. Start producer connection with some dummy url
2. Stop producer.
3. 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.