0

我设置了这个属性，但是 quarkus 不能正常工作。

  • 小黑麦
  • kafka有3个分区
mp:
  messaging:
    incoming:
      event:
        connector: smallrye-kafka
        auto:
          offset:
            reset: earliest
        topic: MY_TOPIC
        group:
          id: my-group
        partitions: 3

我看到我有 3 个不同的消费者 ID，但消息是按顺序处理的。我尝试使用所有 2.X quarkus 版本

任何人都可以帮助我吗？

4

0 回答 0