我目前正在运行一个带有 mqtt 源连接器的 confluent-kafka 实例。我能够查询数据并创建各种流/表，问题是
这三个数据发布到一个 kafka 主题 'x-topic'
<pre><code>{
"orderNumber":"O1",
"deliveryBarcode&#
我在 GKE 集群上运行 java 应用程序 (ksqldb 0.15.0)，并通过了 java opts <code>-Xms3G</code> 和 <code>-Xmx5G</code>。
我正在尝试使用以下 ksql 命令在 ksql cli 中创建 kafka 流。从命令中可以看出，流的来源是kafka topic。
<p
我正在研究一个用例，我正在检查员工在特定时间范围内的加薪次数。我希望窗口大小的时间范围可以
在 <a href="https://kafka-tutorials.confluent.io/" rel="nofollow noreferrer">https://kafka-tutorials.confluent.io/</a> 的一些教程
我正在用 Kafka 和 KSQL 进行一些测试，我想知道如何处理重复键。让我向您展示我的测试用例：
首
我目前正在构建一个 ksqlDB 实例，我打算以交互模式部署它。
我创建了流和表来使用 RocksDB 提供窗
我正在关注此博客以了解 ElasticSearchSink 连接器<br/>
<a href="https://github.com/confluentinc/demo-scene/tree/master/kafka-
我想了解这两种方法之间的区别。我开发了一个项目，因此它使用 Apache Kafka Streams API 聚合了一些数据。
我在我的 Mac 上运行 Kafka/Zookeeper； Kafka 工作正常：我可以使用控制台消费者创建主题并向他们发送/接收
定义模式时如何处理重复的列名。在下面的代码中，尝试为 <code>SOURCES</code> 创建重复列并使用 <code>SOURCE
我在 KSQLDB 中创建了一些虚拟数据作为流
<code>VALUE_FORMAT='JSON' TOPIC='MYTOPIC'</code>
安装程
我测试了主题为 <code>'topic1'</code> 的 Kafka 集群（架构注册表中的架构）。
我从这个主题创建
我有如下所示的 json
<pre><code> {
"customer_id": "CUST002",
"address_code":
有一个主题，包含纯 JSON 消息，试图通过从 JSON 中提取几列和另一列作为带有消息值的 varchar 来创建新
我想实现一个 ksqlDB UDF，它接受一个匹配任何模式的 <code>Struct</code> 实例作为参数。计划是在 UDF 实现中
<strong>用例：</strong>创建一个订单系统来处理移动设备和 Apple 设备的订单。
<ol>
<li>收到订单</li>
<li>
我开始使用 KSQLDB 和 Kafka-connect 进行开发。 Kafka-connect 很棒，一切都很好，并且如果检测到过去已经读取
例如如果按如下方式创建流：
<strong>CREATE TABLE users_original (id VARCHAR PRIMARY KEY) WITH
(kafka_topic='users', va
