I read internals of debezium, but it also can send duplicate messages to kafka, if there is some failure at connector just before updating offset in bin log. In that case, consumer needs to be idempotent. Is there any way we can avoid duplicate message in kafka ??
0 Answers
Related