Buffering the messages before initialization

[shahinghasemi]

Hello, Does this library buffer the messages until it is connected to the Kafka? Consider this scenario:
We deployed our application and the API service is up and running while kafka service has delay (10 to 30 seconds).
Now in this situation the application(API service) might produce messages to topics. The ideal flow is that this library buffer the messages and flush them upon successful connection.

Does this library buffer the produced messages while not connected to the Kafka or they're simply ignored?

[ShogunPanda]

No, it currently does not.
Connections are started ad-hoc depending on topics and partitions.
In your case you would need to accumulate messages in memory and in the meanwhile ask the producer to connect to each involved broker. When all client:broker:connect events are emitted, then you can start flush the in-memory queue.