ksqldb专题提供ksqldb的最新资讯内容,帮你更好的了解ksqldb。
有这样的话题(流)例子: <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=&#39;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>&#34;transforms.pushed_on.type&#34;:&#34;org.apache.kafka.connect.transforms.TimestampConverter$Value&#34;, &#34;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 服务器