有这样的话题(流)例子:
<pre><code>ts S100 S200
----------------
1 11 4
2 12 5
3 13 4
4 17
我有一个运行 ksql 服务器的 kafka 代理。
我有两个主题。大师和细节。
Master 有这些列(“id”
只需使用 Kafka 流和 ksqlDB 即可获得 1:n 关系并将值聚合到新的物化视图/表中。
具有以下 ksqlDB 流:<
我正在尝试在我的 ubuntu 18.04 中设置 KSQLDB。我正在按照以下步骤操作:
<a href="https://docs.ksqldb.io/en/latest/o
我正在 KSQLDB Elasticsearch 连接器上做 PoC。
我正在关注 2 个在线文档:
一:
<pre><code>https://ks
我是 ksqlDB 的新手,所以这可能是我不明白的简单事情。虽然我已经阅读了我能找到的所有文档但没有得
在使用融合的 KSQL 和 Kafka 2.1 的重负载下,我们正在经历持续的消费者组重新平衡。
在看到 kafka 日志后
我正在尝试在 vm(EC2 实例)中设置 Kafka。
我正在尝试使用 wget 下载。但它不是下载只是没有给出
我使用的是 ksqlDB 版本 0.14.0-rc732。
声明一个查询:
<pre><code>CREATE TABLE LIVE_TRAFFIC AS
select
devi
我仍在使用 ksqlDB 来了解它可以做什么和不能做什么,所以我可能会遗漏一些明显的东西。
这是我
我使用这个查询在 KSQLDB 中生成一个表
<pre><code>CREATE TABLE LimiteOneMinute_TB2
WITH (kafka_topic='limitoneminu
如何通过 Rest api 或至少作为 ksqldb-cli 中的语句将 ksql 表中的行标记为删除?
<pre><code>CREATE TABLE movies (
我正在 kafka 流上进行窗口聚合。
它工作正常并正确聚合。
这是 Scala 中的代码。
<code>CallRecord</code> 是一
如何使用 <strong>ksqldb REST API</strong> 接收墓碑值?
表格示例:
<pre><code>CREATE TABLE movies (
title
是否可以在连接丢失后重新连接到相同的推送查询? <a href="https://docs.ksqldb.io/en/latest/developer-guide/ksqldb-re
我正在尝试使用(Confluent)ksqldb-server 通过其 REST 接口使用以下代码(bash 脚本)创建一个 kafka 表:
<
我正在尝试使用 Confluent 的 KSQLDB 在 KAFKA 中创建一个表。我很容易使用 Confluent 提供的 UX,但我正在尝试
<pre><code>"transforms.pushed_on.type":"org.apache.kafka.connect.transforms.TimestampConverter$Value",
"transforms.pushe
所以基本上我想按两列分组,如下所示:
<pre><code>CREATE TABLE foo AS
SELECT a, b, SUM(a)
FROM whatever
GROUP BY a, b
cp-ksql-server helm chart 当前使用的是部署而不是有状态的集合。我想使用有状态集,因为它允许 ksql 服务器