1

我阅读了 debezium 的内部结构，但如果在更新 bin 日志中的偏移量之前连接器出现故障，它也可以向 kafka 发送重复的消息。在这种情况下，消费者需要是幂等的。有什么办法可以避免在 kafka 中出现重复消息？

4

0 回答 0