pipelinedb消费kafka主题

Question

当我在管道中创建一个流，并且它开始消费一个主题时，它没有出现在我的主题的活动consmidores中，我该怎么做才能让它出现在那里呢？

No consumer appears

我是如何创建流的

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中存储偏移量的消费者。

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

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