pipelinedb consuming kafka topic

Question

パイプラインでストリームを作成してトピックの消費を開始すると、トピックのアクティブコンセンサードには表示されませんが、そこに表示されるようにするにはどうすればよいですか？私は、ストリームを作成する方法

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

私は、その値は、あなたの添付のスクリーンショットにあるから引き出さなっている場所を正確にわからないんだけど、私は推測している、それだけで消費者に適用されますカフカにオフセットを格納しています。

あなたはそうのように、消費者のコマンドにgroup_idパラメータを渡すことでpipeline_kafkaとカフカのオフセットを格納することができます：

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