【发布时间】:2020-04-13 11:34:24
【问题描述】:
我有一个包含 6 个分区的主题(我们称之为“my-custom-topic”),并且(实际上)有两个消费者在同一个组中。该组用于服务,我们称其为“myService”。有时,其中一项服务会收到一个 REST 请求,然后它将向“my-custom-topic”发送一个事件。在这种情况下,我想让两个服务都接收事件。 (是的,发送它的人也应该收到它)。稍后,如果我要从“myService”启动其他实例,我也会让它们自动接收此事件。 所以,很快,我想让我在同一个组中的所有服务接收那里的所有消息。 (一次/消息)
如何使用 Kafka 实现这一目标?
谢谢你帮助我。
【问题讨论】:
标签: java spring-boot apache-kafka