代码之家  ›  专栏  ›  技术社区  ›  Kumar Saras

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

  •  0
  • Kumar Saras  · 技术社区  · 1 年前

    我的服务是一个Kafka Streams应用程序,它的应用程序ID设置为主题a中的“service1”消费。我相信这个ID将成为Kafka Stream拓扑中消费者的组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.
    

    提前谢谢。

    0 回复  |  直到 1 年前
        1
  •  0
  •   OneCricketeer Gabriele Mariotti    1 年前

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

    否则,使其成为同一拓扑的一部分。使用Kafka Streams使用这两个主题,并使用分支运算符将主题分开,然后将主题A作为现有代码,然后使用foreach运算符使用主题B,或者其他任何操作

    推荐文章