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主題

回答

相關問題