Pulsar Function 的输入和输出主题可以相同吗?
Can input and output topics be the same for a Pulsar Function?
使用 Pulsar 函数时输入和输出主题相同是反模式吗?
就我而言,我一直只使用一个主题,其中有一个 Cassandra 接收器正在使用消息。我正在考虑创建一个函数,该函数将从该主题读取消息并将转换后的消息发送到同一主题。接收器将能够仅将已处理的消息发送到 Cassandra 中,因为它们将遵守模式。
这是一种不好的做法吗?
我不会推荐它。您需要在函数中过滤转换后的消息,否则会出现无限循环。接收器也必须过滤原始消息。这些过滤器是资源的浪费。
为原始消息和转换后的消息设置不同的主题会好得多。有什么事情阻止你这样做吗?
使用 Pulsar 函数时输入和输出主题相同是反模式吗?
就我而言,我一直只使用一个主题,其中有一个 Cassandra 接收器正在使用消息。我正在考虑创建一个函数,该函数将从该主题读取消息并将转换后的消息发送到同一主题。接收器将能够仅将已处理的消息发送到 Cassandra 中,因为它们将遵守模式。
这是一种不好的做法吗?
我不会推荐它。您需要在函数中过滤转换后的消息,否则会出现无限循环。接收器也必须过滤原始消息。这些过滤器是资源的浪费。 为原始消息和转换后的消息设置不同的主题会好得多。有什么事情阻止你这样做吗?