微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Spring Cloud Stream事件路由功能会自动创建新主题

如何解决Spring Cloud Stream事件路由功能会自动创建新主题

简而言之:启用事件路由功能似乎会自动创建一个routingFunction-out-0主题,我们不知道为什么,但我们不希望如此。怎么样?

某些情况:我们正在使用kafka活页夹连接Azure Eventhub,并使用avro进行serder。当前有四种类型的消息可以发送,它们都继承自抽象的Event类。目前,其中三个实际上都具有相同的属性

最初,我尝试创建一个使用者,使我可以使用Event的所有子类的消息。但是,这引起了问题,因为avro解串器需要确切的类型信息,而不仅仅是父类

这意味着Event的每个子类都有一个特定的使用者。复制不是很好,但是现在我们仍在寻找一种使事情正常进行的方法。问题在于,在同一主题上有4个使用者,并且消息正在发送给错误的使用者(错误类型“ eventsubclass1”正在发送给使用者)。

因此,下一步是尝试使用路由功能,准确地说,是“ routing-expression:headers ['type']”,并在我们要发送的消息中填充type标头。 但是,启用路由功能似乎会创建一个functionRouter-out-0主题,并且eventhub不允许即时创建主题(即使可以,这不是我们想要的东西)做)。

使用本地卡夫卡运行并检查此主题时,没有任何内容发送到该主题。那为什么还在那里呢?有办法禁用这种行为吗?

这是(部分)我们的配置:

spring:
  cloud:
    function:
      routing-expression: headers['type']
    stream:
      function:
        deFinition: ..;functionRouter
      bindings:
        ...
        functionRouter-in-0:
          destination: fup-internal-test
          contentType: "application/*+avro"

如有必要,我很乐意提供更多信息。

编辑:我尝试创建一个名称为“ functionRouter-out-0”的eventhub,但是会自动变为“ function r outer-out-0”。 KafkaTopicProvisioner区分大小写,所以这也是死胡同。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。