pipelinedb verbrauchen kafka topic

Question

Wenn ich einen Stream in der Pipeline erstellen und es beginnt ein Thema zu verbrauchen, erscheint es nicht in den aktiven Consmidores meines Themas, was mache ich, damit es dort erscheint?

No consumer appears

Wie ich den Stream erstellt

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

Answer 1

Ich bin nicht genau sicher, wo dieser Wert von im beigefügten Screenshot gezogen wird immer, aber ich vermute, es gilt nur für Verbraucher, die speichern Offsets in Kafka.

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