我从一个源系统收到了以下事件有效负载
为以下json有效负载创建了Stream1
事件JSON 1
<pre><c
以下是<strong>指标</strong>列中的示例数据：
<pre><code>{
"data": "[{'val': '[{'TS': &
我在窗口上使用cygwin。
并在cygwin上执行以下命令以启动ksql服务器。
<pre><code>bash ksql-server-start .p
我想通过ksql使用Confluent JDBC Sink Connector来写入ClickHouse数据库。
我有一个将数据写入Kafka主题的c＃应用程
我想根据条件将主题<strong> TOPIC_1 </strong>的某些数据（日志）从Kafka <strong>集群A </strong>复制到另一个Kafka
如何在ksql中跟踪源主题偏移进度？
场景：使用过滤条件将事件从源A流到目标B时，如何跟踪是通过
我正在使用Kafka Stream来创建仅包含特定于client_id的数据（不是主题密钥）的ktable。我是Kafka Streams的新手
我想终止查询以删除表。但是我遇到了以下错误，并且在查询终止后，ksql日志不显示任何错误消息。我
我最近开始使用ksql，想检查是否有人可以帮助我进行查询设计。问题陈述是我有一个视频会议应用程序
环境（Docker）：
<pre><code># 5.5.1
image: confluentinc/cp-zookeeper:latest
# 2.13-2.6.0
image: wurstmeister/kafka:latest
# 5.
我正在尝试从本地独立的Confluent Kafka主题连接到Snowflake表。我正在通过<code>ksqldb</code>使用以下连接器配
我试图通过在pom中包含依赖项来访问一些jar文件。问题是我在公司关系仓库中找不到错误。如何告诉Maven
我已将Kafka从5.2.2升级到5.5.1。我可以看到我先前所做的所有主题，但无法从ksqldb获取流和表。有想法吗？
我正在最新版本（融合版本5.5.1）中的AWS EC2实例上测试ksqldb，并且遇到无法解决的访问问题。
我有
我正在将KSQLDB部署在docker容器中，并且在数据库启动时需要创建一些表（如果它们不存在）。有没有办
我们正在使用ksqlDB 0.11.0，我们想将数据持久存储在ksqlDB的表中。但是我们设定
log.retention.hours设置为72，
我已经看到并尝试了许多使用avro的ksql流示例，但似乎它不支持TopicRecordNameStrategy。是
是否可以使用主题
这是一个有关如何将自我管理的ksqlDB / ksql服务器连接到融合云的问题。
我在亚洲南部GCP的<a href="ht
当前ksql的状态使得很难理解哪个版本支持/拒绝/强制/可选的功能。没有明确的版本引用的Confluent文档并
我有一个主题，我正在通过以下格式发送json：
<pre><code> {
"schema": {
"type": "string"
