Hello,
I am trying Camel (2.21.0) with Kafka and something has not the behaviour
that I want:
I have a cluster of 3 Kafka nodes (1 leader, 2 for replication) for 1
partition and 1 topic, when I produce a message in my system, it is
correctly consumed with the Camel components.
But, when I kill the leader node, I get something like (of course, a
follower took the lead) :
*[Consumer clientId=consumer-1,
groupId=924b32bc-9ba4-45ea-9197-c88cf4106696] Connection to node 0 could
not be established. Broker may not be available. *
And it is not possible to consume anymore. If I restart the node, the
message sent when it was down is consumed.
When I was using only the Kafka API, the leader switched automatically, and
I was able to consume from another broker. I would like to have the same
behaviour, but how?
Here is my Springboot configuration for Kafka:
server:
port: 9000
camel:
component:
kafka:
brokers: localhost:9092,localhost:9093,localhost:9094
configuration:
brokers: localhost:9092,localhost:9093,localhost:9094
