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

2022-03-29 Thread Laurentiu Trica
Hi all,

This proved not to be a Camel issue, the Kafka cluster had some unknown
issues, after remaking it, the routes were able to also consume from the
topics even when a broker was down.

Regards,
Laurentiu

On Mon, Mar 28, 2022 at 3:11 PM Laurentiu Trica 
wrote:

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


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

2022-03-28 Thread 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