1回答
我在主题之外创建了一个流，并重新设置了它的键值，因为键为空。 在这个新主题的基础上，我创建了一个表。我们的目标是拥有一个不断更新的对象表(这里是类别)。> postgres中的Categories表： CREATE TABLE categories ( category_namecharacter varying(15) NOT NULL,
浏览 26提问于2019-09-12得票数 1
回答已采纳
1回答
我在需要对数据进行重复数据消除的地方使用KStreams。源接收重复数据的原因有很多，例如数据本身重复、重新分区。当前将Redis用于此用例-其中数据存储如下由于KSQL是在RocksDB之上实现的，它也是一个键值数据库，我可以在这个用例中使用KSql吗？在成功处理时，我会向KSQL中添
浏览 6提问于2021-07-03得票数 0
1回答
我正在尝试创建一个ksql表，以保留实体的最新版本。我想知道这方面的推荐方法是什么。到目前为止，我尝试了以下方法:我通过debezium将发票加载到kafka中，然后创建了以下流，以便能够从ksql使用它们：Debezium在数据库<e
浏览 9提问于2020-03-12得票数 0
回答已采纳
1回答
有没有办法通过jdbc连接器将数据从KSQL导出到mysql表中？？ 我了解了如何使用KSQL将mysql表数据导入到Kafka集群中。但这不是我想要的。docker run -d -p 127.0.0.1:8088:8088 \-e KSQL_LISTENERS=http://0.0.0.0:8088/ \
-e
浏览 44提问于2020-03-17得票数 0
我正在尝试使用ksql二进制文件在流上创建一个表。表被创建并开始运行，但是当我查询它时，表中没有数据。当我使用ksql提示符创建相同的表时，我也能够查询数据。当我使用ksql提示符创建表时，它可以工作。当试图对ksql二进制文件执行相同的操作时，相同的命令不起作用。(*)---------------------------
Table cr
浏览 0提问于2019-06-20得票数 0
回答已采纳
2回答
我在Kubernetes集群的容器中运行了confluent kafka、zookeeper、schema-registry和ksql。Kafka，zookeeper和模式注册表工作得很好，可以创建主题并以Avro格式写入数据，但当我尝试使用curl检查ksql并创建一些流时，例如：
curl -XPOST http://ksql-svc.someapp:8080/ksql -H "Content-Type: application/js
浏览 0提问于2018-03-18得票数 0
在kubernetes或其他环境中，每个应用程序有一个KSQL服务器有意义吗？当我阅读KSQL Server的容量规划时，它似乎是用于在一台服务器上运行多个查询的基本设置。然而，我想要更好地控制Kubernetes的扩展和缩小，固定每个查询的线程数量，并启动kube中配置的服务器，比如说1个cpu，其中只有一个应用程序运行。然而，我不确定KSQL Server有多重，以及这是否有实际意义。
任何建议。
浏览 4提问于2019-07-08得票数 1
1回答
我试图在无头模式下测试ksql。我在查询文件中添加了Create查询并启动服务器， $path-to-ksql/etc/ksql/ksql-server.propertiesTABLE_NAME as from STREAM_NAME
WINDOW TUMBLING (size 1 minute
浏览 0提问于2018-05-30得票数 3
回答已采纳
1回答
我有以下要求，我们正在从一个带有CDC insert/update的关系数据库中读取一个特定表，并将这些作为事件导入到Kafka主题中。1 | C |在流水线的末尾，我们希望每天消费一次这些事件，以避免相同ID的重复。group_id的消费者运行一次(这样offset就存储在kafka
浏览 0提问于2020-06-03得票数 0
1回答
我正在使用CDC和Debezium连接器将中的几个表流到Kafka。其中一个SQL表在KSQL中表示为流，其余的是我希望加入到流中以丰富数据的KSQL表，因此我有一个KSQL流链，每个表都将一个新的KSQL表连接到该链中前一个KSQL流的输出。让A是一个KSQL</e
浏览 0提问于2019-08-09得票数 0
数据看起来是正确的JSON。为了确保，我成功地将它解析为JSON。因此，我使用这个主题创建了一个表，如下所示：(order_num varchar, cust_id integer, order_date integer)该表已成功创建。(StreamThread.java:747)
问题中<e
浏览 0提问于2019-07-02得票数 2
1回答
是否有方法查询KTABLE中的所有当前条目？我正在尝试使用有效负载执行REST的http请求 "ksql": "SELECT * FROM MY_KTABLE;", "auto.offset.reset文件上说
那么，在不需要流的情况下只需要所有当前数据并将KTAB
浏览 4提问于2017-12-11得票数 0
回答已采纳
1回答
我想在与键不同的列上加入两个具有一对多关系的KSQL表。我将给出一个例子，一个上下文，一个我开始研究的解决方案，以及我遇到的问题。创建两个连接器，并创建两个KSQL表(从现在起，所有命令都在KSQL中)：
CREATE SOURCE CONNECTOR teams连接
浏览 3提问于2020-02-18得票数 0
1回答
我在/etc/ksqldb/ksql-server.properties文件中的ksqldb-server中设置了我的模式注册表，就像他们在中所说的那样：我也尝试过使用以下设置，即使不推荐这样做：
SET 'ksql.schema.registry.url'='http://myipaddre
浏览 8提问于2021-09-11得票数 0
2回答
如何确定何时KSQL将数据从Kafka主题完全加载到我的表中？示例：问题： topicC只有来自topicB的数据，所有连接的值都为null。虽然我从create命令获得了成功状态，但
浏览 1提问于2018-11-14得票数 4
回答已采纳
1回答
我已经在我的server.properties文件中添加了以下行：但是，当KSQL启动时，它会显示以下内容：`confluent.support.metrics.enable=false` in the <em
浏览 23提问于2019-08-16得票数 1
回答已采纳
3回答
具有通用应用程序日志(log4j)的第一个主题。存储诸如HTTP请求/响应和警告、异常等.可以有多个日志与一个逻辑业务请求相关联。(这些日志在几秒钟内就会发生)
因此，单个逻辑业务请求可以有多个日志、命令和事件，这些日志、命令和事件由微服务相互传递的uui
浏览 0提问于2018-03-11得票数 6
1回答
我有一个在本地运行的kafka集群和一个名为"my- topic“的主题，在这个主题中我正在推送数据。我还运行了ksql服务器，并且查询: SELECT*FROM "my-topic“给出了"my-topic I not exist”。我知道这个查询是不正确的，我想知道是否有其他方法来查询主题。
浏览 4提问于2018-06-05得票数 1
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
