apache-kafka - pipelinedb消费kafka主题

Question

当我在管道中创建一个流并开始使用一个主题时，它不会出现在我的主题的活动 consmidores 中，我该怎么做才能让它出现在那里？

没有消费者出现

我是如何创建流的

CREATE STREAM pipeline_kafka.summary_device_stream(pack json);
SELECT pipeline_kafka.consume_begin('topicSummaryDevice', 'pipeline_kafka.summary_device_stream', format := 'json');

Answer 1

我不确定您所附屏幕截图中该值的确切位置，但我猜它仅适用于在 Kafka 中存储偏移量的消费者。

pipeline_kafka您可以通过将group_id参数传递给消费者命令来在 Kafka 中存储偏移量，如下所示：

SELECT pipeline_kafka.consume_begin('topicSummaryDevice',
   'pipeline_kafka.summary_device_stream',
    group_id := 'consumer_group_id',
    format := 'json');