That is expected behavior. Typically there are multiple kafka brokers and so if
one is down the client retries to send to a newly elected leader.
A send should not be considered successful until an ACK is received in the
client from the kafka cluster.
By default the ACK is async for perform
The asynchronous sending of a message returns no error even if the
Kafka server is not started.
For all the following tests, the local Kafka server is stopped. First,
consider this piece of code:
public static void main(String[] args) throws Exception {
Properties config = new Properties();
c
