我正在尝试建立一个连接器，该连接器从SQL Server提取数据以与apache kafka一起使用。我已经使用docker-compos
我有一个Kafka主题，该主题接收有关实体的有序更新，因此我使用<strong> LATEST_BY_OFFSET </strong>建立了<strong
嗨，我在下面有一个json。
<pre><code>{
"Obj1": {
"a": "abc",
"b": "def",
我正在运行一个Spring服务，我可以确认是否创建了客户端对象，但是我在日志中看不到任何指示启动或
运行KSQLDB版本：0.12.0
我在加入流时遇到问题。
在将流创建为带窗口的内部联接查询时，右侧
我有一个<code>cities</code>表，其中包含机场列表
<pre><code>TABLE (city VARCHAR PRIMARY KEY, country VARCHAR, airports A
我有一堆防火墙数据。
我想：
A）对每小时每个IP的字节求和，然后
B）计算该小时内所有IP
如何检查流中是否有两个以上的记录来自相同的userId但具有不同的productId。假设我们有一个要发送的流
我正在使用RowSubscribers。该行中是否有任何内容可以告诉我它在哪个窗口中？因为我不想发送每一行的通
我正在使用ElasticsearchSinkConnector将数据从Kafka主题存储到Elasticsearch索引。这是一个Kafka消息的示例：
<p
在尝试使用UDF设置ETL管道时，我遇到了KSQL问题。在ETL流程的某个时刻，我需要从数据中的描述字段（VARC
我想从Debezium源主题在ksqlDB中创建表，最终目的是对这些表执行左连接，并使用JDBC接收器连接器将物化
阅读一些文章后，我了解到ksqdb表实际上是聚合流。意思是它显示当前业务状态。不是业务历史。业务历
我在Kubernetes集群（带有Kafka集群，v2.4.0，已经与Strimzi一起部署）上部署了<code>ksqlDB</code>服务器，具有以
想知道是否有可能支持<code>ksqlDB</code>，如果可以，那么可能会付出多少努力。
我愿意进一步研究
这看起来应该很简单！
（我使用的所有其他CLI工具都具有易于安装的过程。）
我们正在Kubernetes集
我正在关注此 <a href="https://www.confluent.io/blog/how-real-time-materialized-views-work-with-ksqldb/" rel="nofollow noreferrer">l
问题是，我将使用 KSQL 将原始 kafka 主题架构更改为新的嵌套架构
这是我当前的 kafka 主题架构和字段：</
我将以下 json 发送到名为“订单”的 kafka 主题：
<pre><code>{
"clientId":"007",
"region":
我目前是该领域的新手，正在研究 KSQLDB。我想从其中包含地图属性的 JSON 数据创建子流。
我的 JSON
