Camel Kafka connector can't consume from cluster if one broker is down

[Laurentiu Trica]

Hi,

I'm using Camel 2.54 in Karaf 4.3.6 and producing/consuming messages
to/from a Kafka cluster with 3 brokers.
I've tested shutting down a broker to see if the producing/consuming
continues and found out that it's not the case.

Camel *can still send messages to Kafka* (after setting the retries > 0), *but
it doesn't consume messages anymore.*

Everything *works again when the broker comes online again*.

Do you know about this behavior? Is there something I'm missing?

Producer config:
kafka:TOPIC1?brokers=kafka1:29092,kafka2:29092,kafka3:29092&retries=100

Consumer config:
kafka:TOPIC1?brokers=kafka1:29092,kafka2:29092,kafka3:29092&groupId=GROUP1&autoOffsetReset=earliest&maxPollRecords=1

Many thanks!
Laurentiu