【发布时间】:2020-02-09 06:14:20
【问题描述】:
我们的项目有微服务架构。有一个微服务,其中调度程序触发向 Kafka 发送消息的逻辑。问题是,如果有多个微服务实例,那么每个微服务实例都会向 Kafka 发送一条消息。如何实现所有生产者之间的幂等性?我的意思是,如果“相等”的消息将与不同的生产者一起发送到 Kafka,那么它只会在日志中提交一次。
【问题讨论】:
标签: apache-kafka microservices spring-kafka kafka-producer-api idempotent