Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
KSQL - 删除主题
有没有办法从 KSQL 中删除该主题 根据github https github com confluentinc ksql blob 4 0 x ksql engine src main java io confluent ksql dd
ApacheKafka
ksqldb
Ksql:Left Join 显示流中的列,但不显示表
我在 KSQL 中有一个蒸汽和一张表 如下所述 流名称 DEAL STREAM 表名称 EXPENSE TABLE 当我运行以下查询时 它仅显示流中的列 但不显示表列 这是预期的输出吗 如果不是 我做错了什么吗 SELECT TD EXPE
ApacheKafka
ksqldb
从 Spring Boot 应用程序运行 KSQL 的方式是什么
我有一个连接到 kafka 集群的 Spring Boot 应用程序 如何从 java 代码运行 KSQL 目前 还没有直接的方法在java中使用KSQL作为库 有一个开放的问题 734 https github com confluent
ksqldb
是否可以从 ksql 流创建 ksql 表?
我是 ksql 的新手 我只是在玩阅读卡夫卡主题到流 效果很好 另外 尝试从 kafka 主题创建表并失败 意识到我需要在 kafka 主题中设置一个键 该键被视为 ksql 表中的主键 所以我尝试从流创建表 但也失败了 查询 脚本 CRE
ApacheKafka
ksqldb
KSQL查询线程数
有没有办法指定在 KSQL Server 上运行的 KSQL 查询应消耗的线程数 换句话说就是查询的并行性 KSQL Server 上可以运行的应用程序数量有限制吗 何时或如何决定横向扩展 是的 您可以指定ksql streams num
ksqldb
从 Kafka 获取最新值
我有一个卡夫卡主题叫做A 主题中的数据格式A is id 1 name stackoverflow created at 2017 09 28 22 30 00 000 id 2 name confluent created at 2017
ApacheKafka
apachekafkastreams
ksqldb
显式指定 KSQL 流主题名称
我有两个 KSQL 主题my topic 1 and my topic 2 消息通过 AVRO 序列化 由于历史原因 my topic 1架构不在推荐范围内topic value格式 而是my custom subject name 我想通
ApacheKafka
Avro
ksqldb
KSQLDB Emit Final 不返回任何值
我在 ksqldb 上进行了以下查询 如果我使用 EMIT CHANGES 它确实可以工作 但如果将其更改为 EMIT FINAL 它在窗口结束后不会返回任何值 CREATE TABLE sspc 3536660 v4 as select
ApacheKafka
ksqldb
Kafka 到 Snowflake 连接问题
我正在尝试从本地独立 Confluence Kafka 主题连接到 Snowflake 表 我正在使用以下连接器配置ksqldb CREATE SINK CONNECTOR snowflake sink WITH name snowflak
ApacheKafka
snowflakeclouddataplatform
ksqldb
KSQL 流 - 从结构数组中获取数据
我的 JSON 看起来像 Obj1 a abc b def c ghi ArrayObj key1 1 Key2 2 Key3 3 key1 4 Key2 5 Key3 6 key1 7 Key2 8 Key3 9 我已经编写了 KSQL
ApacheKafka
ksqldb
confluentplatform
KSQL 表-表左外连接多次发出相同的连接结果
使用 KSQL 并执行左外连接 我可以看到有时多次发出的连接结果 换句话说 相同的连接结果会被多次发出 我不是在谈论右侧具有空值的联接版本和不具有空值的版本 从字面上看 连接产生的同一条记录会被多次发出 我想知道这是否是预期的行为 一般答案
ApacheKafka
ksqldb
是否可以在 Confluence KSQL 查询中使用多个左连接?尝试加入超过 1 个表的流,如果没有,那么解决方案是什么?
溪流 describe ammas Field Type ROWTIME BIGINT system ROWKEY VARCHAR STRING system ID INTEGER 对于运行时统计信息和查询详细信息 运行 DESCRIBE
ApacheKafka
confluentplatform
ksqldb
如何从 ksqldb 表中删除值或插入逻辑删除值?
如何通过 Rest api 或至少作为 ksqldb cli 中的语句来标记 ksql 表中的行以进行删除 CREATE TABLE movies title VARCHAR PRIMARY KEY id INT release year
ksqldb
如何在nodejs中编写KSQL查询?
您能为我提供一个在 Kafka 上运行 KSQL 查询的 Node js 代码示例吗 F e 我想创建and然后检索一个简单的表 哎呀 没有图书馆可以为你做到这一点 您是否考虑过使用 REST api 来实现此目的 https docs c
nodejs
ApacheKafka
ksqldb