pipelinedb消费kafka主题

当我在管道中创建一个流并开始占用一个主题时，它不会出现在我的主题的活动consmidores中，我该怎么做以便它出现在那里？pipelinedb消费kafka主题

如何创建的流

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

来源

2017-04-25 luiz kava

我不知道究竟在何处是价值正从你的附截图拉升，但我猜它仅适用于消费者，在卡夫卡储存抵消品。

您可以与卡夫卡通过pipeline_kafka传递group_id参数给消费者的命令，像这样保存偏移：

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

来源

2017-04-26 19:08:39

严重的错误:( ** SQL错误[42883]：错误：功能pipeline_kafka。 consume_begin（未知，未知，group_id =>未知，format =>未知） Dica：没有函数与给定的名称和参数类型匹配您可能需要添加明确的类型转换 Posição：8 org.postgresql。 util.PSQLException：错误：函数pipeline_kafka.consume_begin（unknown，unknown，group_id => unknown，form at => unknown）不存在 Dica：没有函数与给定的名称和参数类型相匹配。您可能需要添加显式类型转换。 Posição：8 ** –

您输入的确切命令是什么导致了这个错误？ –

此命令... 'SELECT pipeline_kafka.consume_begin（'topicNotificationProcess'，'pipeline_kafka.sensor_event_process_stream'，format：='json'，group_id：='groupEventProcess'; batchsize：= 4330，parallelism：= 5，start_offset： = -1）;' –

pipelinedb消费kafka主题

回答

相关问题