Pulsar Function 的输入和输出主题可以相同吗?

Posted

技术标签:

【中文标题】Pulsar Function 的输入和输出主题可以相同吗?【英文标题】:Can input and output topics be the same for a Pulsar Function? 【发布时间】:2022-01-12 13:35:13 【问题描述】:

使用 Pulsar 函数时输入和输出主题相同是一种反模式吗?

就我而言,我只使用了一个主题,其中有一个 Cassandra 接收器在使用这些消息。我正在考虑创建一个函数来读取来自该主题的消息并将转换后的消息发送到同一个主题。接收器将能够仅将处理后的消息接收到 Cassandra,因为它们会尊重架构。

这是一种不好的做法吗?

【问题讨论】:

【参考方案1】:

我不会推荐它。您需要在函数中过滤转换后的消息,否则会出现无限循环。接收器也必须过滤原始消息。这些过滤器是资源的浪费。 对于原始消息和转换后的消息,最好有不同的主题。有什么事情阻止你这样做吗?

【讨论】:

不,我可以有多个主题。

以上是关于Pulsar Function 的输入和输出主题可以相同吗?的主要内容,如果未能解决你的问题,请参考以下文章

05_Pulsar的主要组件介绍与命令使用名称空间Pulsar的topic相关操作Pulsar Topic(主题)相关操作_高级操作

Pulsar 消息概念2

Apache Pulsar 主题复制随着集群大小的增加

Apache Pulsar 中的主题复制

在 Apache Pulsar 中使用注册模式发布到主题

从 apache pulsar 主题中检索所有过去的消息