如何确保我认为通过 kafka 进行的微服务交互是正确的？

How to make sure microservices interactions via kafka I think up are correct?

假设我有一个发出 kafka 事件的微服务，微服务处理程序将通过 kafka 侦听器处理它。处理程序微服务应该扩展，我相信我应该通过我的流中的 kafka 组 ID 来做到这一点，但我不明白如果一个微服务已经开始处理一个事件，其他处理程序将如何不处理发出的 kafka 事件的机制。你能帮我理解一下吗？

使用相同的消费者组，为他们提供相同的 groupdId。这样，只有其中一个能够使用每条消息

你可以阅读更多相关内容here