how about kafka test

kafka is a distributed, partitioned, replicated commit log service message queue, i am interesting how kafka test. transaction message ,exactly once message ,replication ,any document about kafka test? how to ensure kafka work as except? -- = fu

about Exactly-once Semantics

I read the great blog about kafka Exactly-once Semantics . my question is when consumer receive msg,and process the msg result save to db(eg.MySQL),how to keep Exactly-once Semantics. I think the k

about Kafka Client rebalance

hello I read the Kafka Client source code .Client do rebalance when receive JoinGroupResponse if it is the client leader.if it is not a leader,it don't rebalance? when has many Kafka Client and them same groupId,how to do rebalance? thanks all. org.apache.kafka.clients.consumer.internals.A