Hi,

Partition may be reassigned if the consumer is not reachable. Will partition 
reassignment cause same message being processed in parallel?
Suppose if Kafka found consumer A is not reachable (maybe because of network 
problem), it assigns the partition to consumer B. But actually consumer A is 
still running, this may cause the situation that a same message is processed in 
parallel by consumer A and consumer B. If the logic in processing the message 
includes updating some database tables, we have to lock some rows first. If 
such parallel processing the same message can not happen, we needn't use lock.
Appreciate if you can provide some information on this.

Best regards,
Yun

Reply via email to