我们如何把卡夫卡的话题抛到presto



我需要将JSON文件推送到Kafka主题中,将主题连接到presto中,并将JSON数据结构化为可查询的表。

我正在学习本教程https://prestodb.io/docs/current/connector/kafka-tutorial.html#step-双载数据

我无法理解这个命令将如何工作。

$/kafka tpch加载--代理localhost:9092--前缀为tpch--tpch型微型

假设我已经使用生产者在卡夫卡中创建了测试主题。tpch文件将如何生成此主题?

如果您已经有一个主题,您应该跳到步骤3,在那里它实际上设置了要通过Presto 查询的主题

kafka-tpch load创建具有指定前缀的新主题

Above命令创建一个tpch模式并在其下加载各种表。这可以用于测试目的。如果你想使用实际的kafka主题,你需要将它们登记在/cacatalog/kafka.properties中,以对抗kafka.tables-names。如果你只是提供一个没有前缀的主题名称(如test_topic(,它将进入";默认";架构。但是,如果您指定了一个带前缀的主题名称(例如testrongchema.test_topic(,那么该主题将显示在testrongchema下。在使用presto进行查询时,可以提供此模式名称。

相关内容

  • 没有找到相关文章

最新更新