我们在我们的项目中拥有微服务架构。有一个微服务，其中调度程序触发向Kafka发送消息的逻辑。问题是，如果有多个微服务实例，那么每个微服务实例都会向Kafka发送一条消息。如何在所有生产者之间实现幂等？我的意思是，如果“相等”的消息将与各个生产者一起发送到Kafka，则仅在日志中提交一次。
您不能那样做。生产者是独立的。