从ksql流到ksql表的聚合结果错误
可能是由于以下原因导致的：
- 数据不一致：流和表之间的数据不一致可能导致聚合结果错误。这可能是因为流中的数据在到达表之前被修改或删除，或者由于网络延迟导致的数据丢失。
- 聚合逻辑错误：聚合操作中的逻辑错误可能导致结果错误。例如，使用错误的聚合函数、错误的分组字段或错误的过滤条件等。
- 数据类型不匹配：流和表之间的数据类型不匹配可能导致聚合结果错误。例如，将字符串类型的数据聚合为数值类型时可能会出现错误。
为了解决这个问题，可以采取以下措施：
- 数据一致性保证：确保流和表之间的数据一致性。可以使用事务或其他数据同步机制来保证数据的准确性和完整性。
- 检查聚合逻辑：仔细检查聚合操作的逻辑，确保使用正确的聚合函数、分组字段和过滤条件。可以使用调试工具或日志来帮助定位问题。
- 数据类型匹配：确保流和表之间的数据类型匹配。可以使用类型转换函数或映射来处理不匹配的数据类型。
对于腾讯云的相关产品和服务，以下是一些推荐的产品和链接：
- 腾讯云流计算（Tencent Cloud StreamCompute）：提供实时流数据处理和分析的服务。链接：https://cloud.tencent.com/product/sc
- 腾讯云数据仓库（Tencent Cloud Data Warehouse）：提供高性能、可扩展的数据仓库解决方案。链接：https://cloud.tencent.com/product/dw
- 腾讯云消息队列（Tencent Cloud Message Queue）：提供可靠的消息传递服务，用于流数据的异步处理和分发。链接：https://cloud.tencent.com/product/cmq
- 腾讯云数据库（Tencent Cloud Database）：提供各种类型的数据库服务，包括关系型数据库、NoSQL数据库等。链接：https://cloud.tencent.com/product/cdb
请注意，以上推荐的产品仅供参考，具体选择应根据实际需求和情况进行评估。
相关·内容
我有apache访问日志文件，我想在cassandra表中存储每个页面的访问计数(总数/每天/每小时)。
我正在尝试使用kafka连接从日志文件流到kafka主题。为了在Cassandra中增加指标计数器，我可以再次使用Kafka Connect吗？否则，这里应该使用哪些其他工具，例如kafka streams，spark，flink，kafka connect等？
浏览 0提问于2017-10-11得票数 0
1回答
我正在使用CDC和Debezium连接器将中的几个表流到Kafka。其中一个SQL表在KSQL中表示为流，其余的是我希望加入到流中以丰富数据的KSQL表，因此我有一个KSQL流链，每个表都将一个新的KSQL表连接到该链中前一个KSQL流的输出。
让A是一个KSQL流。
设B到D是KSQL表。
A+B= A‘
A‘+C=A’
A‘+D= A'’
这对A‘和A'’很好，但是A‘给了我一个错误：Source table (D) key column (X) is not the column used in the join criteria (Y).为什么我能够在没有事故的情况下生
浏览 0提问于2019-08-09得票数 0
1回答
我正在寻找关于KSQL存储查询和表的位置的文档。例如，由于KSQL是为使用Kafka而构建的，因此当我从主题创建表时，或者当我编写查询时，表或查询结果存储在哪里？更具体地说，KSQL是使用某种类型的指针指向主题分区内的段内的事件，还是在我从主题创建表时复制事件？
浏览 12提问于2019-10-30得票数 1
回答已采纳
是否有方法使用KSQL将消息拆分为多个消息并发布到新主题。首先，我并不是在寻找一个基于Java的监听器，而是将它迭代/流到一个新的主题；相反，我正在寻找一个为我做到这一点的KSQL。
例如：
比方说，我需要invoice主题中的消息拆分成item_inventory_delta消息
发票主题
键：销售检查号
消息示例：
{
"total": 12.33,
"salecounter": 1,
"items": [
{
"itemId": 123,
浏览 4提问于2019-12-03得票数 1
回答已采纳
1回答
已尝试使用SSL配置架构注册表。尝试将HTTPS架构注册表与AVRO Producer一起使用时，失败并显示错误
No SAN Name found
我已配置为忽略主机名检查。但还是不起作用。类似的配置在KAFKA REST、CONNECT和KSQL上也有效。
ALso尝试从使用模式注册表的KSQL运行查询。失败，错误与找不到SAN名称的错误相同。
下面是HTTPS架构注册表上的配置；
listeners=https://0.0.0.0:8081
ssl.keystore.location=/confluent-5.5.0/cert/kafka.server.keystore.jks
ssl.
浏览 5提问于2020-05-12得票数 0
我正在使用Databricks Autoloader递增地从database表流到SQL数据库。如果对Delta表运行优化或真空语句，则会添加/减去新文件。
我的问题是，autoloader检查点会在下一个流中对这些优化的文件进行折扣吗？还是我的整个Delta表会被流到SQL中，因为autoloader不承认它已经处理了数据？
浏览 1提问于2021-08-02得票数 4
1回答
我正在尝试设置kafka和ksql使用汇合平台，但ksql无法启动。
使用这个链接安装kafka和ksql的步骤我跳过了zookeeper，因为我们没有使用多台服务器和控制中心部分。在我开始了动物园管理员，卡夫卡，模式-注册表，卡夫卡-连接，卡夫卡-休息，这个顺序。同时使用命令检查状态
_sudo systemctl status confluent*_
ksql failed to start, while everything else is running.
在进入cd /etc/ksql/ksql-server.properties时
(#------ Endpoint config
浏览 0提问于2019-08-27得票数 0
回答已采纳
我在ksql中有一个名为turnstile_stream的流。对于该流中的列值(station_id)，当我查询所有条目时，会得到以下结果
ksql> select * from turnstile_stream where station_id = 40820 emit changes;
+----------------------------------------------------+----------------------------------------------------+--------------------------------------------
浏览 8提问于2020-02-03得票数 0
我是新来的蜜蜂。我只是玩卡夫卡的主题读流，这是伟大的工作。
同时，试图从卡夫卡主题创建一个表格，但失败了。意识到我需要在kafka主题中设置一个键集，它被认为是ksql表中的主键。因此，我尝试从流创建表，但也失败了。查询/脚本：
CREATE TABLE DETAILS_TABLE AS SELECT SEQ, Server1, ServerId, NumberUri, SERVERID2, SERVER2 FROM details_stream WINDOW TUMBLING (SIZE 1 MINUTES);
Invalid result type. Your SELECT query p
浏览 0提问于2018-05-05得票数 6
回答已采纳
1回答
有没有办法通过jdbc连接器将数据从KSQL导出到mysql表中？？ 我了解了如何使用KSQL将mysql表数据导入到Kafka集群中。但这不是我想要的。 docker run -d -p 127.0.0.1:8088:8088 \
-e KSQL_BOOTSTRAP_SERVERS=my-cluster:9092 \
-e KSQL_LISTENERS=http://0.0.0.0:8088/ \
-e KSQL_KSQL_SERVICE_ID=kakaoblog_ksql \
-e somthing is be here...
confluentinc/cp-ksql-server:5
浏览 44提问于2020-03-17得票数 0
我对Apache Kafka和kSQL完全陌生。我的脑海中有一个问题，我试图找到答案，但我没有做到。 我目前的理解是，从生产者生成的事件在Kafka内部以序列化形式(0和1)存储在主题中。如果我创建一个Kafka流来使用数据，然后运行kSQL查询，假设使用COUNT()函数，那么该查询的输出将持久化在Kafka主题中。 如果是这样的话，它不会是存储成本吗？
浏览 9提问于2021-04-30得票数 1
1回答
我读过这篇文章，。看来我一件事都不懂。
例如，当新消息到达时，使用COUNT更新记录。这意味着KSQL知道如何找到特定的记录以便更新它。对此有一个查询：
CREATE TABLE pageviews_per_region AS
SELECT regionid,
COUNT(*)
FROM pageviews
GROUP BY regionid
EMIT CHANGES;
GROUP BY子句中的列名是否有助于KSQL查找特定记录？
浏览 4提问于2020-02-23得票数 0
回答已采纳
我想终止一个查询来删除一个表。但是我得到了下面的错误，在查询终止后，ksql日志不会打印任何错误消息。如何找到根本原因？
ksql>终止CTAS_KSQL1_TABLE_SACMES_PACK_STATS_275；
无法将语句“”terminate CTAS_KSQL1_TABLE_SACMES_PACK_STATS_275；“”写入命令主题。“
原因:等待命令主题消费者处理命令主题超时
浏览 1提问于2020-08-28得票数 1
我有一张不足1000张唱片的ksql表。当我运行这个查询select * from table_name时，在查询开始返回任何数据之前需要10秒的时间。
运行Kafka、、ksql和schema注册表的机器没有重载或类似的东西。
我使用的是1 broker和1 ksql服务器的dev安装程序。
该表具有简单的非嵌套json，有两个字段，即电子邮件和用户id。
这是一个问题，因为我不能将它用于单个查找，例如，使用这样的查询
SELECT * FROM TABLE_NAME WHERE col='value';
因为返回结果的时间太长了。我预计结果会立即返回。
如果我使用流而不是表
浏览 0提问于2019-05-24得票数 2
回答已采纳
1回答
我正在尝试构建一个从MySql到Ksql的数据管道。
用例:数据源是MySql。我在MySql中创建了一个表。
我在用
./bin/connect-standalone ./etc/schema-registry/connect-avro-standalone.properties ./etc/kafka-connect-jdbc/source-quickstart-sqlite.properties
若要启动独立连接器，请执行以下操作。而且效果很好。
我正在以主题名称启动消费者，即
./bin/kafka-console-consumer.sh --bootstrap-server lo
浏览 0提问于2018-10-23得票数 1
回答已采纳
基本上，当我在查询中使用group by表达式时，我正在尝试获取所有列。
从主题创建流
CREATE STREAM events_stream \
( \
account VARCHAR, \
event_id VARCHAR, \
user_name VARCHAR, \
event_name VARCHAR, \
source VARCHAR, \
message VARCHAR, \
timestamp STRUCT<iMillis INTEGER>) \
WITH (KAFKA_TOP
浏览 0提问于2019-02-18得票数 2
Collect_LIST的KSQL说：
他的版本将结果数组的大小限制为最多1000个条目，超过此限制的任何值都会被忽略。
沉默是特别恼人的。我需要一个无限的版本。我需要和KTable一起使用它。
我正在考虑实现一个用户定义的功能，然而，在我开始这个旅程之前，我想了解为什么会有这样的任意限制？它能以某种方式配置吗？
EDIT1：
可以用一个表来处理：
select addressid, collect_list(name) from users group by addressid;
The aggregation function(s) (collect_list) canno
浏览 0提问于2019-07-09得票数 1
我正在使用Kafka将一些数据传输到Kafka。我可以使用print 'kdc-01-orders' from beginning;查看这些数据。数据看起来是正确的JSON。为了确保，我成功地将它解析为JSON。
因此，我使用这个主题创建了一个表，如下所示：
create table orders
(order_num varchar, cust_id integer, order_date integer)
with
(kafka_topic='kdc-01-orders', value_format='json', key='orde
浏览 0提问于2019-07-02得票数 2
我有一个包含客户记录的卡夫卡主题，叫做“客户创造的”。每个客户都是该主题中的新记录。有4个分区。
我有两个基于docker映像confluentinc/cp-ksql-server:5.3.0的ksql服务器实例正在运行。两者都使用相同的。
我创造了一张桌子：
CREATE TABLE t_customer (id VARCHAR,
firstname VARCHAR,
lastname VARCHAR)
WITH (KAFKA_TOPIC = 'customer-created&#
浏览 1提问于2019-08-02得票数 1
回答已采纳
所需的功能:对于给定的键key123，多个服务并行运行，并将其结果报告到单个位置，一旦为key123收集了所有结果，这些结果就会传递给新的下游使用者。
最初的想法:使用亚马逊网络服务的DynamoDB来保存给定条目的所有结果。每次准备好结果时，微服务都会对key123上的数据库执行修补操作。输出流检查每个更新以查看条目是否完整，如果是，则将其转发到下游。
新想法:使用Kafka Streams和KSQL来达到相同的目标。所有服务都将它们的输出写入结果主题，该主题形成了一个更改日志Kstream，我们可以在KSQL中查询已完成的条目。类似于：
CREATE STREAM competed_res
浏览 9提问于2019-07-12得票数 0
请问创建表时可以设置键字段吗？ 我通过聚合创建了一个表，如下所示： CREATE TABLE withdrawal_less_than_5min AS
SELECT executedate, status, count(*) as count
FROM TB3_WITHDRAW_RECORD_EXCLUDE_INTERNAL_USERS
GROUP BY executedate,status; 当我执行DESCRIBE EXTENDED withdrawal_less_than_5min时，表的关键字段设置如下，我认为它应该是执行日期和状态。 Key field
浏览 25提问于2019-03-15得票数 2
我正在使用Kafka REST API从curl POST发布到ksql，如果我不使用LIMIT20，它会挂起。另外，如果我再次使用它来查询表，它就会挂起。我在python脚本中运行这个脚本，在这里我在两行之间查询，因为我不能从流中获得最新的结果，因为它是连续和持久的。
data = {"ksql":"SELECT MAX(ROWTIME),TIMESTAMPTOSTRING(ROWTIME, 'yyyy-MM-dd HH:mm:ss'),MYFIRMWAREVERSION,MYBASEMACID,BOOTTS,IMEI,PRODDEVICESERIAL
浏览 2提问于2018-12-12得票数 2
我想连接到我自己的Kafka实例，以便尝试KSQL。我下载了最新版本的Confluent开源平台-
我遵循并尝试从Git Bash在我的Windows10机器上启动KSQL服务器：
ksql-server-start ksql-server.properties
但它失败了，并显示以下错误：
Error: Could not find or load main class io.confluent.ksql.rest.server.KsqlServe
浏览 20提问于2018-08-25得票数 0
回答已采纳
我对KSQL表的理解是，它们显示的是数据的"as “视图，而不是所有数据。因此，如果我有一个简单的聚合查询，并且我从我的表中选择，我应该在此时看到数据。
我的数据(流)：
MY_TOPIC_STREAM:
15 | BEACH | Steven Ebb | over there
24 | CIRCUS | John Doe | an adress
30 | CIRCUS | Alice Small | another address
35 | CIRCUS | Barry Share | a home
35 | CIRCUS | Garry Share
浏览 5提问于2020-05-25得票数 2
回答已采纳
1回答
对于KTable本身由一个Kafka主题定义的KSQL查询，我得到了意想不到的结果。KTABLE是“贸易”，它的背后是紧凑的主题"localhost.dbo.TradeHistory“。它应该包含由TradeId键控的股票交易的最新信息。主题的关键是TradeId。每个交易都有一个AccountId，我正在构建一个查询，以获得按帐户分组的交易金额的总和。
贸易的定义
ksql> create table Trades(TradeId int, AccountId int, Spn int, Amount double) with (KAFKA_TOPIC = 'local
浏览 3提问于2019-10-12得票数 1
回答已采纳
当试图从现有的Kafka主题创建KSQL中的Stream时，我面临以下错误。
io.confluent.ksql.exception.KafkaTopicExistsException:名称为“ -data”的卡夫卡主题已经存在，具有不同的分区/副本配置。KSQL需要两个分区(主题有一个)和一个复制因子(主题有一个)。
在KSQL中创建流必须有两个分区吗？
浏览 1提问于2019-11-13得票数 1
我正在使用ksql流并每5分钟计算一次事件。这是我的疑问-
select count(*), created_on_date from TABLE_NAME window tumbling (size 5 minutes) group by created_on_date;
提供结果-
2 | 2018-11-13 09:54:50
3 | 2018-11-13 09:54:49
3 | 2018-11-13 09:54:52
3 | 2018-11-13 09:54:51
3 | 2018-11-13 09:54:50
没有窗口滚动的查询-
select count(*), created_
浏览 0提问于2018-11-13得票数 0
1回答
KSQL表无法查看数据
、、、
合流平台: 6.1.1 问题:无法查看ksql表上的数据:- 1.)第一次创建的主题:- ./kafka-topics --zookeeper localhost:2181 --create --partitions 1 --replication-factor 1 --topic COUNTRY-CSV
Created topic COUNTRY-CSV. 2.)向此主题发送了一些数据： ./kafka-console-producer --broker-list localhost:9092 --topic COUNTRY-CSV --property parse.key=true --
浏览 34提问于2021-05-09得票数 0
我正在研究一些工作，我们必须证明Kafka和KSQL作为POC的一部分的价值。我们正在处理简单的游戏事件，玩家可以进行游戏，而游戏引擎要么给他们分配分数(被认为是胜利)，要么他们什么也得不到(被认为是输球)。我们的要求之一是证明在连续亏损或获胜时使用KSQL的可行性。为了这个问题的目的，我将集中讨论连续损失。
我们有两张表，一张是赢的，一张是输掉的，这两张表都是针对同一场比赛事件的。
wins DDL如下：
CREATE TABLE TABLE__GAME_EVENTS__WINS AS
SELECT userId,
gameName,
浏览 1提问于2019-10-10得票数 2
我想要达到的目标：
我们有一个假设卡夫卡集群。我想在OpenShift中设置KSQLDB，并将它连接到假设Kafka集群的代理。
问题：
当我尝试用"/usr/bin/ksql- server -start /etc/ KSQLDB /ksql-server.properties“命令启动ksqldb服务器时，我会得到错误消息：
[2020-05-14 15:47:48,519] ERROR Failed to start KSQL (io.confluent.ksql.rest.server.KsqlServerMain:60)
io.confluent.ksql.util.Ksql
浏览 8提问于2020-05-15得票数 1
回答已采纳
1回答
我们的JavaScript程序每秒使用kafka-rest异步写入20条消息。我们尝试对传入的消息进行聚合，但返回了一些不一致的结果。
请在下面找到主题、流和聚合结果表定义。
主题：
./bin/kafka-avro-console-producer –broker-list localhost:9092 –topic order_flow –property value.schema='{“type”:”record”,”name”:”myrecord”,”fields”:[{“name”:”OrderID”,”type”:”int”},{“name”:”OrderDate”,”ty
浏览 0提问于2018-03-30得票数 0
1回答
我有一个Kafka Streams应用程序，它需要在全局表上加入一个传入流，然后在经过一些处理之后，将聚合的结果写回该表：
KeyValueBytesStoreSupplier supplier = Stores.persistentKeyValueStore(
storeName
);
Materialized<String, String, KeyValueStore<Bytes, byte[]>> m = Materialized.as(
supplier
);
GlobalKTable<String, String> table
浏览 1提问于2018-06-22得票数 4
回答已采纳
我使用查询"Create base_stream with“(kafka-topic ="myTopic"，format="avro")创建了一个流，这个主题拥有超过800 of的数据并在不断增长。
问题：
是否复制了新流中底层主题中的数据？或者是相同的数据?当KSQL服务器重新启动时，base_stream丢失了其数据。有任何方法来持久化这些数据吗？因为，如果每次KSQL server重新启动时都必须重新同步/重新创建base_stream，这可能需要许多小时！我知道可以从"base_stream“创建持久流，但是，我们将在2 streams
浏览 0提问于2020-02-24得票数 0
1回答
我创建了一个Kafka主题，我在这个主题上创建了一个KSQL流，我在这个流上创建了一个表来进行聚合，在重启KSQL Server和kafka之后，所有的KSQL流和表都消失了！有没有办法将KSQL Server配置为将流和表保存在桌面上？它是否只将数据存储在RAM上？
浏览 2提问于2018-11-08得票数 0
在我的Scala应用程序中，我试图告诉我的KSQL，它应该使用RUN SCRIPT <script>函数执行KsqlRestClient.makeKsqlRequest(String ksql)命令。每次我尝试它时，都没有发生任何事情，即使响应是成功的，所以我开始调试，在这里我看到响应是成功的，但它也返回了某种错误，即属性ksql.schema.file.content是空的。
因为我没有找到任何文档来填充这个属性，所以我尝试了一些东西，最后发现如果用.sql文件的内容填充这个属性，运行脚本命令就能工作。
有没有人知道是否和用什么填充ksql.schema.file.content
浏览 0提问于2018-03-29得票数 0
1回答
我有一个场景，在这个场景中，我需要在Kafka中导入一个完整的DB，并在DB术语中创建一些用户可以查询的表的视图。我的要求是通过物理模型(表)中的视图重新构建逻辑模型。
因此，我想知道这样做的步骤。
我的理想是，kafka创建与表相对应的主题，然后由我声明性地(使用KSQL)创建视图。
虽然我在这里描述的东西一开始听起来是可行的，但是我对数据--主题中的数据的结构(模式)--有一个问题。问题似乎是，我可能不得不做一个额外的步骤，但不知道它是否可以避免或实际上是必要的。
更具体地说，视图通常表示表上的联接。我想，如果我想要在表上加入，我需要已经创建了Ktable或Kstream，这给出了要在其上
浏览 2提问于2019-07-06得票数 0
回答已采纳
2回答
如何确定何时KSQL将数据从Kafka主题完全加载到我的表中？
目标：取2个卡夫卡主题，加入他们并将结果写成一个新的卡夫卡主题。
示例：
我正在使用Ksql的Rest发出以下命令。
CREATE TABLE MyTable (A1 VARCHAR, A2 VARCHAR) WITH (kafka_topic='topicA', key='A1', value_format='json');
CREATE STREAM MyStream (B1 varchar, B2 varchar) WITH (kafka_topic='topicB&#
浏览 1提问于2018-11-14得票数 4
回答已采纳
请找到下面的问题，并确认相同的。
步骤-01:基于连接条件，从表和填充中获得值。由于表B中没有匹配值，所以所有列都被填充为空值。
专栏: B.OP_TYPE，B.DEMO_ID
ksql> SELECT PLAN_ID,A_OP_TYPE,B.OP_TYPE,A.PRIMARY_DEMO_ID,B.DEMO_ID \
FROM TBL_PLN_PRO_DIV_SDIV A \
LEFT JOIN TBL_MS_TARGET_GROUP11 B \
ON (A.PRIMARY_DEMO_ID=B.DEMO_ID);
382591 | U | null | 3085 | null
相同的s
浏览 0提问于2018-09-22得票数 0
回答已采纳
1回答
我正在编写POC，我必须读取管道分隔的值文件，并将这些记录插入ms sql server中。我使用Content5.4.1来使用value_delimiter创建流属性。但它的例外：Delimeter only supported with DELIMITED format
1.开始汇合(版本: 5.4.1)::
[Dev root @ myip ~]
# confluent local start
The local commands are intended for a single-node development environment
only, NOT for pr
浏览 2提问于2020-03-11得票数 0
我使用的是confluent Platform版本5.4.1的社区版。我没有找到任何用于打印KSQL Server版本的CLI命令，但是当我进入KSQL时，可以在附加的屏幕截图中找到我看到的内容。
我有一张地理栅栏表-
CREATE TABLE GEOFENCE (GEOFENCEID INT,
FLEETID VARCHAR,
GEOFENCECOORDINATES VARCHAR)
WITH (KAFKA_TOPIC='MONGODB-GEOFE
浏览 12提问于2020-06-04得票数 3
溪流：
describe ammas;
Field | Type
-------------------------------------
ROWTIME | BIGINT (system)
ROWKEY | VARCHAR(STRING) (system)
ID | INTEGER
-------------------------------------
运行时统计信息和查询详细信息运行：DESCRIBE EXTENDED <S
浏览 0提问于2018-07-21得票数 3
我已经从标准Ubuntu18.04/20.04/等安装了几个apache服务器。我想监视它们处理了多少请求。我现在正在研究普罗米修斯&格拉法纳( prometheus & grafana )，在15+多年来一直在“忍受”nagios & munin之后。
是否有apache报告“自从服务器启动以来，我已经处理了X 200请求，Y 404请求等等”？mod_status没有报告这一点。我想，如果我能够访问这些统计数据，那么我就可以绘制出有多少人在使用web服务器，并可能检测到一些故障(通过查找大量500 s)。
浏览 0提问于2021-10-13得票数 0
我正在尝试使用(Confluent) ksqldb-server通过其REST接口使用以下代码(bash脚本)创建一个kafka表：
KSQLDB_COMMAND="CREATE TABLE sample_table \
(xkey VARCHAR, \
xdata VARCHAR) \
WITH (KAFKA_TOPIC=\'sample-topic\', \
VALUE_FORMAT=\'JSON\', \
KEY=\'xkey\'); "
COMMAND="curl -X
浏览 18提问于2021-02-24得票数 0
回答已采纳
我已经创建了以下Docker容器来运行zookeeper、kafka、ksql和ksql-cli。当我从正在运行Docker的同一台计算机上运行命令docker-compose exec ksqldb-cli ksql http://ksqldb-server:8088时，ksql-cli可以很好地访问ksql-server。
但是，我希望能够访问同一台机器之外的ksql-server，但在同一个本地网络下使用不同的笔记本电脑。我该怎么做？
下面是相关的docker-compose.yml文件：
version: '3.8'
services:
zookeeper:
浏览 4提问于2022-01-04得票数 0
回答已采纳
1回答
我正在编写这个卡夫卡流应用程序，它接收被注册在卡夫卡主题中的传感器读数(在JSON中作为消息)，并在每分钟、每小时和每天的基础上对这些读数的值执行一些聚合。然后，我将从这些聚合中派生的KTables具体化，并使用默认状态存储存储它们。我想知道是否可以使用KSQL查询这些表。
浏览 1提问于2019-10-01得票数 1
回答已采纳
1回答
我在/etc/ksqldb/ksql-server.properties文件中的ksqldb-server中设置了我的模式注册表，就像他们在中所说的那样：
ksql.schema.registry.url=http://myipaddress:8090
但是当我进入ksqldb容器时：
docker exec -it ksqldb-cli ksql http://ksqldb-server:8088
我试着跑：
CREATE STREAM tracking WITH (KAFKA_TOPIC='tracking', VALUE_FORMAT='AVRO');
我
浏览 8提问于2021-09-11得票数 0
使用ksqlDB，我已经创建了一个带有自定义查询的JDBC连接器。然后，根据生成的kafka主题，我创建了一个表。但是，从表中选择只返回主键的数据，而返回所有其他值的null。我正在连接的postgres数据库的sales表不断更新新数据，我正尝试使用ksql流式传输这些数据。 ksql> CREATE SOURCE CONNECTOR con WITH (
'connector.class' ='io.confluent.connect.jdbc.JdbcSourceConnector',
'connection.url
浏览 27提问于2020-11-30得票数 0
回答已采纳
1回答
我从很长一段时间以来都在和克克尔一起工作。Kafka聚类为3个节点。我也一直在使用udf，直到我停止服务器并重新启动它们为止，一切看起来都很好。在服务器启动时，我在日志中看到了以下内容：
[2019-04-03 11:29:54,381] ERROR Exception encountered running command: A Kafka topic with the name 'czxcorp-structured-data-enriched' already exists, with different partition/replica configuration t
浏览 0提问于2019-04-03得票数 0
回答已采纳
我正在尝试使用KAFKA主题在KSQL中创建一个表，该表已成功创建。当我尝试从表中选择数据时，我得到了错误 org.apache.kafka.common.errors.SerializationException: Failed to deserialize key from topic: ah_topics_2639_sales. Can't convert type. sourceType: ObjectNode, requiredType: BIGINT, path: $ Caused by: io.confluent.ksql.serde.json.KsqlJsonDese
浏览 186提问于2021-11-16得票数 0
回答已采纳
我正在尝试使用ksql二进制文件在流上创建一个表。表被创建并开始运行，但是当我查询它时，表中没有数据。当我使用ksql提示符创建相同的表时，我也能够查询数据。
PS:我正在设置这个属性集‘auto.offset.Reset’=‘最早’；以开始查询数据表单。
两种方法我都试过了。当我使用ksql提示符创建表时，它可以工作。当试图对ksql二进制文件执行相同的操作时，相同的命令不起作用。
sudo echo "CREATE TABLE movie_table AS SELECT title, count(*) AS appearance FROM test WHERE year >
浏览 0提问于2019-06-20得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
云直播
对象存储活动推荐
腾讯云开发者
