Hey Paolo,
When you use the subscribe() API, you are using Kafka for group
coordination. All members with the same group.id will balance the
partitions of subscribed topics between themselves. When you use assign(),
no such balancing takes place but you can still using Kafka to store
offsets.
Hi devs,
I have one simple topic named "test" with only one partition. then ...
I have a consumer C1 using assign() for having assigned partition 0 of topic
"test" and this consumer has group.id = "mygroup"
I have another consumer C2 using subscribe() for having assigned partitions
from topic
