Suppose I have a topic say testTopic and it has three partitions say [0,1,2]. I have slightly different usecase where I would be having multiple consumer with different consumer-Id's listening on specific partition of a topic(say partition 0). Elaborating - I want three consumers namely c1 (group-id firstGroup), c2 (group-id secondGroup) and c3(group-id thirdGroup) handling events only from partition 0 of testTopic.
Question -
I have tried to read doc, it has partitionAssigners but I can't understand how to use it? Is it place which can solve my usecase? or this is not supported in this library?
augustoViegas2
commented
3 months ago
Describe the bug
testTopicand it has three partitions say[0,1,2]. I have slightly different usecase where I would be having multiple consumer with different consumer-Id's listening on specific partition of a topic(say partition 0). Elaborating - I want three consumers namely c1 (group-id firstGroup), c2 (group-id secondGroup) and c3(group-id thirdGroup) handling events only from partition0oftestTopic.Question -
partitionAssignersbut I can't understand how to use it? Is it place which can solve my usecase? or this is not supported in this library?