Hi there,
I think what you're asking is how the group protocol can guarantee that
each partition is assigned to one and only consumer in the group at any
point in time. Is that right? The short answer is that it can't. Because of
unexpected pauses on the client (e.g. for garbage collection), there
Hi,
after reviewed Kafka 0.9.0 code, I have a rebalance question:
coordinator will choose a client as leader to execute assign, after
transfer it to coordinator, when assignments are Propagate to each member in
consumer group,how can it sure one partition is only owned by a consum
