pipelinedb使用kafka主题

z31licg0 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(304)

当我在管道中创建一个流并且它开始使用一个主题时，它不会出现在我的主题的活动consmidores中，我该怎么做才能使它出现在那里？
没有消费者出现
我是如何创建流的

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

apache-kafka pipelinedb

来源：https://stackoverflow.com/questions/43617433/pipelinedb-consuming-kafka-topic

1条答案

按热度按时间

wh6knrhe1#

我不确定在你所附的截图中这个值到底是从哪里来的，但我猜它只适用于在Kafka存储偏移量的消费者。
您可以使用 pipeline_kafka 通过一个 group_id 参数，如下所示：

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

赞(0）回复(0）举报 2021-06-07

我来回答

pipelinedb使用kafka主题

1条答案

相关问题

热门标签

最新问答