我们的项目中有微服务架构。有一个微服务,调度器触发向Kafka发送消息的逻辑。问题是,如果有多个微服务实例,那么每个实例都会向Kafka发送一条消息。如何在所有生产者之间实现幂等?我的意思是,如果'equal‘消息将被发送给Kafka和不同的生产者,那么它将只在日志中提交一次。
发布于 2019-10-12 08:04:11
你不能这么做。生产者是独立的。
https://stackoverflow.com/questions/58345971
相似问题