绑定中单个通道的多重消费者组和目的地

发布于 2025-02-09 14:32:50 字数 683 浏览 2 评论 0原文

因此，我试图为多个主题目的地和消费者组 提供一个函数。但是我坚持语法。我正在尝试实现以下操作，但不确定是否可能，如果是application.yl

function : handleEvent

topics: topicAEvent, topicBEvent, topicCEvent
consumer group : AEventConsumergroup, BEventConsumergroup, CEventConsumerGroup

application.yml

spring:
 cloud:
  function:
   definition: handleEvent;
  stream:
   kafka:
    bindings:
     handleEvent-in-0:
      group: AEventConsumergroup, BEventConsumergroup, CEventConsumerGroup
      destination: topicAEvent, topicBEvent, topicCEvent

是否有办法具有一个可以为多个KAFKA主题和消费者组提供消费者BEAN的单个功能？

原文

So I am trying to have a single function for multiple topic destinations and consumer groups. However I am stuck with the syntax. I am trying to achieve the below, but not sure if that's possible and if it is then what will be the syntax in the application.yml

function : handleEvent

topics: topicAEvent, topicBEvent, topicCEvent
consumer group : AEventConsumergroup, BEventConsumergroup, CEventConsumerGroup

application.yml

spring:
 cloud:
  function:
   definition: handleEvent;
  stream:
   kafka:
    bindings:
     handleEvent-in-0:
      group: AEventConsumergroup, BEventConsumergroup, CEventConsumerGroup
      destination: topicAEvent, topicBEvent, topicCEvent

Is there a way to have a single function that can provide Consumer Bean for multiple kafka topics and consumer groups?

分享到QQ

分享到微博