当前位置: 首页 > 知识库问答 >
问题:

我们怎样才能把Kafka的话题抛到最前面

楚奇逸
2023-03-14

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

共有1个答案

姜献
2023-03-14

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

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

 类似资料:
  • 我怎么能把这条线移到右边。我正在使用智能的想法,我使用了导致问题的自定义字体。

  • 如何获取用户当前所在的路由?我需要它来隐藏导航栏链接,如果用户当前在链接通向的路线上。

  • 如果我的问题看起来很长,我道歉。我会尽量简明扼要。 问题:编写一个程序,将以千克为单位的估算重量转换为磅。如果用户输入负值,程序应要求玩家重新输入数字。 我创建了三个函数。第一个函数-返回玩家输入第二个函数-返回以磅为单位的权重第三个函数-如果权重为正,返回以磅为单位的值,或者如果值为负,要求另一个输入。 如果相同的值为正数,我的程序将返回正确的值。然而,当我输入一个负浮点数时,我的程序将永远打印

  • 发生在我身上的是MDB接收消息并尝试处理它们,甚至我的服务器也没有完全启动 知道怎么解决这个问题吗?

  • 我有一个用户模型和一个学生模型,我已经为它们建立了关系,但是当我尝试 $学生- 我得到这个错误 “正在尝试获取非对象的属性全名” 以下是我的用户模型代码: 这是我的学生模型代码 即使我试图利用这种关系来获取数据,比如 “学生id”= 我得到这个错误 “对未定义方法Illumb\Database\Eloquent\Relations\BelongsTo::id()的BadMethodCallExce

  • 我试图把Flink和德鲁伊联系起来。 然而,我不知道如何正确地做到这一点。 在此Flink留档中,"bootstrap.servers"设置为"localhost:9092"。 这是否意味着我可以使用Apache Kafka摄取直接连接,因为下面设置了示例主管规范? 除了Flink,我还需要管理Kafka吗?或者我应该做其他事情来连接Flink和德鲁伊?