1回答
我有两个流，每个流都是从一个主题定义的，在这个主题上发布的JSON消息有点像这样：它们对应的流定义如下：WITH (kafka_topic='mytopic', value_format='JSON'
浏览 18提问于2020-03-13得票数 0
回答已采纳
我在Json中有一个有50个字段的流式主题。我尝试使用主题中的KSQL创建另一个包含1个字段的流，如下所示：已成功创建流，但以下KSQL查询未返回任何数据：它
浏览 0提问于2019-01-24得票数 0
这是一个关于如何将自管理的ksqlDB / ksql服务器连接到汇合云的问题。/home/confluent/confluent-5.5.1/etc/ksqldb/ksql-server.properties流已在终端中成功创建，但在云中不可用。命令“显
浏览 0提问于2020-09-07得票数 0
1回答
我正在使用CDC和Debezium连接器将中的几个表流到Kafka。其中一个SQL表在KSQL中表示为流，其余的是我希望加入到流中以丰富数据的KSQL表，因此我有一个KSQL流链，每个表都将一个新的KSQL表连接到该链中前一个KSQL流的输出。让A是一个KSQL流</
浏览 0提问于2019-08-09得票数 0
我已经创建了一个KSQL脚本来执行流表连接。除了join之外，我还根据流执行过滤器。我已经部署(交互式/无头)并测试了it.Is，它可以从外部/属性设置过滤条件，以便能够以不同的配置运行。
浏览 2提问于2019-04-05得票数 0
我们需要监听多个主题，并在每个主题的事件中查找特定的字段。每个主题事件都是json格式的，并且要求json格式的固定字段很少。需要从所有这些多个主题中筛选事件，并在每个事件有效负载中查找特定字段。如果此字段值与特定格式匹配，则将这些来自不同主题的事件发送到一个固定主题，该主题可由另一个使用者进一步处理。我正在寻找ksql是否可以在这种情况下有所帮助-我们从多个主题创建一个流，并根据
浏览 2提问于2018-10-30得票数 0
1回答
我的理想是，kafka创建与表相对应的主题，然后由我声明性地(使用KSQL)创建视图。
虽然我在这里描述的东西一开始听起来是可行的，但是我对数据--主题中的数据的结构(模式)--有一个问题。我想，如果我想要在表上加入，我需要已经创建了Ktable或Kstream，这给出了要在其上执行连接的结构。此时，我可以使用KSQL<
浏览 2提问于2019-07-06得票数 0
回答已采纳
1回答
我正试图在ksql cli中创建一个kafka流，并使用下面的ksql命令。从命令中可以看出，流的来源是kafka主题。STREAMWITH kafka_topic = 'testtopic',);
这个kafka主题，使用模式bytes mac字段。其他字段(deviceId、inNetwork、
浏览 1提问于2021-03-30得票数 1
我想对来自多个主题的数据使用相同的连接器。另一个主题中的消息将有一个不同的键，我需要转换它。我想知道是否有一种方法可以使用具有主题名称或消息中单个字段的条件的if else语句，这样我就可以以不同的方式转换键。所有传入的消息都是带有模式和有效负载的json。基于应答的更新
在我的jdbc连接器
浏览 0提问于2018-10-03得票数 1
回答已采纳
3回答
具有通用应用程序日志(log4j)的第一个主题。存储诸如HTTP请求/响应和警告、异常等.可以有多个日志与一个逻辑业务请求相关联。(这些日志在几秒钟内就会发生)
因此，单个逻辑业务请求可以有多个日志、命令和事件，这些日志、命令和事件由微服务相互传递的uui
浏览 0提问于2018-03-11得票数 6
1回答
我使用汇合JDBC连接器将消息发布到主题中。源连接器将在每次轮询中向主题发送数据和架构。我想检索这个架构。我的目的是创建一个KSQL流或基于模式构建的KSQL流或表，由Kafka连接器进行投票。
浏览 0提问于2018-11-22得票数 2
回答已采纳
1回答
我使用模式注册表将avro消息写入kafka主题。然后根据主题创建流。使用当前架构创建的尖叫。删除并重新创建模式对我来说是有问题的，因为我有许多其他流\表依赖于它。KSQL不允许丢弃具有依赖关系流。
浏览 2提问于2018-09-06得票数 3
您好，我正在试用KSQL，发现大多数文档都提供了与kstream或ktable直接连接的示例。假设我已经由团队X创建了两个流，并且我不能更改它或重新创建新的流，并且还想使用现有的流。在这里，默认情况下，连接时将为时间戳列考虑rowtime。是否有其他方法可以将现有流中的rowtime列指定为时间戳列，并考虑其在KSQL中的连接时间窗口。
浏览 0提问于2019-09-03得票数 0
我有一个场景，在10个表的顶部创建了一个连接。当连接在数据库中完成时，这是非常有效的。现在，这些表是通过Kafka主题流数据(1:1 - table:topic映射)。到目前为止，我已经决定将这些数据存储在像Cassandra这样的NoSQL DB中，并在事件不断发生时更新已加入的记录。以下是我的问题：
坚持卡桑德拉的解决方案提供了一个更好<e
浏览 2提问于2018-10-05得票数 0
回答已采纳
Debezium MySQL连接器看起来配置正确，工作正常，但是当我基于主题在KSQL中构造流或表时，所有列值都返回为null。CREATE TABLE tbl_clients (id, appname STRING) WITH (KA
浏览 0提问于2019-07-16得票数 0
-------------------------------------表-01：-------------------------------------------------
试图加入流与表-01正像预期的那样工作将流最终流创建为从a.id中选择ammas，这是a.id = b.id上的</em
浏览 0提问于2018-07-21得票数 3
1回答
= { 'b' : 'b1' 'c' : 'a1'考虑到数据(payload)来自卡夫卡，我想看到payload_transform在消费者身上的转换有可能用ksql吗？payload = { 'b' : 'b1'至 'confluent&
浏览 0提问于2018-03-21得票数 1
回答已采纳
我在KSQL中有一个蒸汽和一个表，如下所述：表名: EXPENSE_TABLE这是预期的产出吗。TD.EXPENSE_CODE = TE.EXPENSE_CODE查询的输出如下所示
浏览 0提问于2018-04-25得票数 2
回答已采纳
1回答
我对Kafka Streams非常陌生，我试着创建一个poc，看看它是否适合我的用例。 我有一个主题，在这个主题中我正在制作一些参考数据。然后，这些数据被流式传输并转换为一个GlobalKTable CPK (我使用了一个GlobalKTable，因为我需要在非关键字上加入)。一旦这个过程完成。然后，我开始填充另一个主题，该主题随后流式传输(SPT)数据，并在CPK上执行内部连接以生成另一个GlobalKTable (JTK)。 CPK和SPT都是来自外部系统的摘要。现在我有了实时数据，
浏览 12提问于2020-04-19得票数 0
回答已采纳
我有两个基于docker映像confluentinc/cp-ksql-server:5.3.0的ksql服务器实例正在运行。两者都使用相同的。并不陌生，但我的理解是，KSQL构建在Kafka流之上，并且每个ksql-server实例大致等同于Kafka流应用程序实例。我注意到的第一件事是，一旦我启动了ksql-server的新实例，它就已经知道在第一个实
浏览 1提问于2019-08-02得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
