我可以在 Kafka Streams 拓扑和普通 Kafka 消费者之间使用相同的组 ID 吗？

Question

我的服务是一个 Kafka Streams 应用程序，假设应用程序 ID 设置为“service1”，从主题 A 消费。我相信这个 ID 成为 Kafka Streams 拓扑中消费者的组 ID。现在，我想使用 Micronaut Kafka 创建一个新的简单消费者，以从同一服务中的不同主题（主题 B）进行消费。有没有办法也使用“service1”作为 Micronaut Kafka 消费者的组 ID？我尝试输入相同的 ID，但开始出现以下错误：

The group member's supported protocols are incompatible with those of existing members or first group member tried to join with empty protocol type or empty protocol list.

提前致谢。

Answer 1

您可以在同一个应用程序中创建两个单独的消费者组。使用相同的东西没有任何好处。

否则，使其成为同一拓扑的一部分。使用 Kafka Streams 使用两个主题并使用分支运算符来拆分主题，然后将主题 A 作为您现有的代码，然后可以使用 foreach 运算符或其他操作来使用主题 B