基于kafka消费者组实现消息广播

具体场景

有3个不同的应用程序或服务（如：app1、app2、app3）需要接收这些消息。

任务实现

实现广播的方法：创建多个消费者组

为了实现广播，需要为每个接收广播消息的实体创建一个独立的消费者组。例如，假设有一个主题 topic1 包含需要广播的消息，并且有 3 个不同的应用程序（或服务）需要接收这些消息。为每个应用程序创建一个消费者组，这样每个消费者组都可以独立地从 topic1 中消费消息，从而实现消息的广播。