Hi,

I am trying to place multiple kafka consumers of a single consumer group in
the same process. But, I am unable to put more than 3 consumers in the same
process.The topic which the consumer group tries to read has 10
partitions.When I try to attach the 4th consumer, it leaves the group after
the first poll, with below message. No partitions get assigned to the
consumer.

[ForkJoinPool.commonPool-worker-3] INFO
org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer
clientId=consumer-group65-4, groupId=group65] Member
consumer-group65-4-b148f7ec-b852-46ed-8514-c3af3bd78395 sending LeaveGroup
request to coordinator my-cluster:9092 (id: 2147483645 rack: null) due to
the consumer is being closed

What is the reason for this? Is there any way to put more than 3 consumers
in the same process?

Thank you
-- 
Lahiru Chandima

Reply via email to