如何在KSQLDB中的输出主题上构造嵌套的JSON消息
我从一个源系统收到了以下事件有效负载 为以下json有...
KSQL嵌套json需要将密钥保存在多行中
以下是<strong>指标</strong>列中的示例...
错误：找不到或加载主类Folder.confluent-5.5.1-2.12.tar.confluent-5.5.1-2.12.confluent-5.5.1.logs
我在窗口上使用cygwin。 并在cygwin上执行以下命令以...
格式化数据以通过ksql使用Confluent JDBC Sink连接器
我想通过ksql使用Confluent JDBC Sink Connector来写...
使用KSQL将数据从一个Kafka集群复制到另一个Kafka集群是否可行？
我想根据条件将主题<strong> TOPIC_1 </st...
如何在ksql中跟踪源主题偏移进度？
如何在ksql中跟踪源主题偏移进度？ 场景：使用过滤条...
Kafka Stream-按client_id过滤
我正在使用Kafka Stream来创建仅包含特定于client_i...
ksqldb cli无法终止查询：等待命令主题使用者处理命令主题时超时
我想终止查询以删除表。但是我遇到了以下错误，并且...
怎样在KSQLDB中实现LAG之类的实现？
我最近开始使用ksql，想检查是否有人可以帮助我进行...
从主题创建表，并得到一些有关LongDeserializer接收的数据大小不是8的序列化异常
环境（Docker）： <pre><code># 5.5.1 ...
Kafka与Snowflake的连接问题
我正在尝试从本地独立的Confluent Kafka主题连接到S...
无论我放在pom文件中什么内容，mvn build都会不断检查nexus仓库
我试图通过在pom中包含依赖项来访问一些jar文件。问...
为什么升级后ksqldb不显示流？
我已将Kafka从5.2.2升级到5.5.1。我可以看到我先前所...
为什么我可以读取ksqldb流，但不能读取ksql客户端中的主题？
我正在最新版本（融合版本5.5.1）中的AWS EC2实例上...