Here’s the code:

@Override
public void send(Key key, Value value) {
        kafkaTemplate.send(topicName, key, value).get(10, TimeUnit.SECONDS);
}

Steps to reproduce:

1. Start sending an event.
2. Disable kafka container.
3. Waiting for TimeoutException.
4. Enable Kafka container.

Expected result: The message has not been sent.
Actual result: Message delivered to consumer.

I know that KafkaTemplate may use queue inside, and it sends async. Maybe it’s something wring with timing properties? Thanks.