KSQL表无法查看数据
KSQL是一种流式处理引擎，用于实时处理和分析流式数据。它是基于Apache Kafka构建的，可以通过SQL语法进行流数据的查询、转换和聚合操作。
KSQL表无法查看数据可能是由以下几个原因导致的：
- 数据尚未到达：KSQL是实时处理引擎，它处理的是流式数据。如果数据尚未到达Kafka主题，那么KSQL表中就无法查看到数据。可以通过检查数据源是否正常发送数据，以及Kafka主题是否正确配置来解决此问题。
- 查询条件不匹配：在执行查询时，如果查询条件与KSQL表中的数据不匹配，那么就无法查看到数据。可以检查查询条件是否正确，并确保与KSQL表中的数据字段匹配。
- 数据格式错误：KSQL要求数据以特定的格式进行序列化和反序列化。如果数据格式不正确，KSQL就无法正确解析数据并将其加载到表中。可以检查数据格式是否符合KSQL的要求，并进行必要的格式转换。
- 表定义错误：如果KSQL表的定义与实际数据不匹配，就无法正确加载数据。可以检查表的定义是否正确，并确保与实际数据的结构一致。
针对KSQL表无法查看数据的问题，腾讯云提供了一系列相关产品和解决方案，例如：
- 腾讯云消息队列 CKafka：提供高可用、高吞吐量的消息队列服务，可作为Kafka的托管服务，用于存储和传输流式数据。
- 腾讯云流计算 Flink：基于Apache Flink构建的流式计算引擎，可用于实时处理和分析流式数据。
- 腾讯云数据仓库 TDSQL-C：提供高性能、高可靠的云原生数据仓库服务，可用于存储和查询大规模数据。
更多关于腾讯云相关产品的详细信息，请访问腾讯云官方网站：https://cloud.tencent.com/
相关·内容
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
1回答
嗨，我已经离开了使用Ksql表(NGINX_TABLE)加入Ksql ( SEARCHREQUESTDTO)。使用下面的ksql命令
CREATE STREAM NIGINX_SEARCH_QUERY AS \
SELECT *\
FROM SEARCHREQUESTDTO\
LEFT JOIN NGINX_TABLE\
ON SEARCHREQUESTDTO.sessionid = NGINX_TABLE.sessionid;
成功地生成了流NIGINX_SEARCH_QUERY。此外，我还可以在Ksql终端中看到使用show命令的NIGINX_SEARCH_QUERY
浏览 0提问于2018-09-05得票数 1
我正在尝试使用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
回答已采纳
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
我想终止一个查询来删除一个表。但是我得到了下面的错误，在查询终止后，ksql日志不会打印任何错误消息。如何找到根本原因？
ksql>终止CTAS_KSQL1_TABLE_SACMES_PACK_STATS_275；
无法将语句“”terminate CTAS_KSQL1_TABLE_SACMES_PACK_STATS_275；“”写入命令主题。“
原因:等待命令主题消费者处理命令主题超时
浏览 1提问于2020-08-28得票数 1
步骤：
我们创建了一个名为pgsqlcountry的卡夫卡主题，它包含来自postgreSQL DB的所有流数据。
我们创建了一个名为country的流，用于将主题处理为一个表。
流已成功创建。
-
ksql> describe country;
Field | Type
------------------------------
ROWTIME | BIGINT
ROWKEY | VARCHAR(STRING)
ID | BIGINT
COUNTRY | VARCHAR(STRING)
CREATED_AT | BI
浏览 3提问于2017-11-15得票数 1
1回答
我创建了一个Kafka主题，我在这个主题上创建了一个KSQL流，我在这个流上创建了一个表来进行聚合，在重启KSQL Server和kafka之后，所有的KSQL流和表都消失了！有没有办法将KSQL Server配置为将流和表保存在桌面上？它是否只将数据存储在RAM上？
浏览 2提问于2018-11-08得票数 0
1回答
我试图在表和流之间执行连接，但由于某种原因，它无法工作。
ksql> SELECT GROUP_TABLE.SOCIETY_ID, GROUP_TABLE.ID FROM GROUP_TABLE;
1 | 2
^CQuery terminated
ksql> SELECT DEVICE_STREAM.GROUP_ID FROM DEVICE_STREAM
2
^CQuery terminated
ksql> SELECT GROUP_TABLE.SOCIETY_ID FROM DEVICE_STREAM LEFT JOIN GROUP_TABLE ON DEVICE_STR
浏览 7提问于2020-07-14得票数 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回答
我正在尝试让我的ksqldb服务器对接实例连接到远程Kafka集群，但是得到了一个错误。以下是细节
docker-compose.yml
---
version: '2'
services:
ksqldb-server:
build:
context: .
dockerfile: ./Dockerfile
hostname: ksqldb-server
container_name: ksqldb-server-remote
ports:
- "8088:8088"
environ
浏览 20提问于2022-04-21得票数 0
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
回答已采纳
1回答
我在需要对数据进行重复数据消除的地方使用KStreams。源接收重复数据的原因有很多，例如数据本身重复、重新分区。
当前将Redis用于此用例-其中数据存储如下
id#object list-of-applications-processed-this-id-and-this-object
由于KSQL是在RocksDB之上实现的，它也是一个键值数据库，我可以在这个用例中使用KSql吗？
在成功处理时，我会向KSQL中添加一个条目。在接收时，我必须检查该id在KSQL中是否存在。
根据事件处理领域的KSql设计，它的用例是否正确？
浏览 6提问于2021-07-03得票数 0
1回答
从KSQL表中读取数据
、、、、
也许这是一个初学者的问题，但是读取KSQL中产生的数据的推荐方法是什么呢？
假设我进行了一些流处理，并将数据写入到KSQL表中。现在，我想通过Spring应用程序访问这些数据(例如，通过websocket扇出一些实时数据)。我在这里的第一个猜测是使用Spring Kafka并订阅底层主题。或者我应该使用Kafka Streams？
另一种用例可能是进行流处理，并将结果写入Redis存储(例如，对于总是返回当前值的use服务)。这里的方法是什么？
谢谢!
浏览 21提问于2017-12-28得票数 6
我对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
回答已采纳
我正在使用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
2回答
如何在KSQL中执行1个-> N关系
我有一个表，bob_id作为主键，另一个表将有多个行，foo_id作为主键，bob_id作为外键。
如何使用KSQL复制这种情况？
据我所知，KSQL没有外键。
并且我们不能在ksql中联接表，除非该列是主键。
重新分区不起作用，因为我使用的是表，而不是流。
浏览 0提问于2018-11-29得票数 0
1回答
我正在尝试创建一个ksql表，以保留实体的最新版本。我想知道这方面的推荐方法是什么。
到目前为止，我尝试了以下方法:我通过debezium将发票加载到kafka中，然后创建了以下流，以便能够从ksql使用它们：
ksql> create stream invoice_stream with (kafka_topic='dbserver1.invoices.invoice', value_format='AVRO');
Debezium在数据库表行的状态之前和之后添加数据，这使得使用起来有点困难，因此我在顶层创建了另一个流，只获取我感兴趣的数据：
creat
浏览 9提问于2020-03-12得票数 0
回答已采纳
1回答
我可以在KSQL中成功地创建和查看表和流，但它们不会显示为主题，因此我可以在Java Kafka Consumer上使用它们。 正在发生的事情的简要介绍： ksql> CREATE TABLE RTSHTABLE (primaryKey BIGINT, secondaryKey BIGINT) WITH (KAFKA_TOPIC = 'rtsh', VALUE_FORMAT='JSON', KEY='primaryKey');
Message
---------------
Table created
---------------
浏览 16提问于2019-04-16得票数 0
回答已采纳
我有一个将(X，Y)坐标保存到SQL表的系统。然后，我有一个端点，当被调用时，它返回(X，Y)坐标。 但是，我的系统需要30分钟来处理(X，Y)坐标并将其存储到SQL表中。从这个意义上说，我使用KSQL来更快地获取数据。 我已经在我提到的后端的端点中添加了对KSQL的调用。问题是这个调用给我的请求增加了6秒的额外时间。 我的端点包含一个查询，如下所示 SELECT feature_a,feature_b FROM ksql_table; 之前的两个流已经对ksql_table进行了预处理。在我的理解中，这个查询应该是非常简单和容易计算的。但这需要6秒的时间来处理。
浏览 29提问于2019-02-04得票数 1
回答已采纳
2回答
我对KSql很陌生，但对卡夫卡来说并不新鲜。我有现有的主题，在卡夫卡作为Avro序列化数据存在。我已经启动并运行了合流模式-注册表，并将KSql配置为指向注册表。
当我试图创建一个基于我的主题之一的表时，KSql抱怨说它找不到流。当我试图在KSql中创建一个流，该流只是在KSql中流我的主题时，似乎没有办法指向我的Avro序列化主题，该主题在注册表中有一个引用。
有人知道如何解决这两个问题吗？我想使用KSql的方式不适合它所能做的事情吗？
更新
下面是更多的细节
ksql> show topics;
Kafka Topic
浏览 0提问于2018-08-06得票数 1
我正在使用KSQL为一个车队管理系统跟踪停靠之间的延迟，为了简单起见，我有两个流trips和tasks，它们从debezium获得数据馈送，到目前为止还不错。
我的问题是，当我创建一个反映一些聚合数据的KSQL表时，我假设支持主题最终应该有一个压缩的结果，但实际上并非如此，如下面的示例所示
-- trips stream
CREATE STREAM trips_raw (
id bigint, gross_merchandise_value double, vehicle_id bigint, trip_code string,
status s
浏览 4提问于2021-03-24得票数 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
回答已采纳
我使用的是汇合平台v7.0.1的托管版本：
CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES
e6963904b485 confluentinc/cp-enterprise-control-center:7.0.1 &
浏览 8提问于2022-02-18得票数 0
回答已采纳
我将以以下方式使用合流版本3.3.0设置ksql-cli
#zookeper
docker run -d -it \
--net=host \
--name=zookeeper \
-e ZOOKEEPER_CLIENT_PORT=32181 \
confluentinc/cp-zookeeper:3.3.0
#kafka
docker run -d \
--net=host \
--name=kafka \
-e KAFKA_ZOOKEEPER_CONNECT=localhost:32181 \
-e KAFKA_ADVERT
浏览 0提问于2018-04-11得票数 1
回答已采纳
我已经使用KSQL创建了一个流和该流的聚合表。
{
"ksql":"DROP Stream IF EXISTS StreamLegacyNames; DROP Stream IF EXISTS StreamLegacy; CREATE Stream StreamLegacy (payload STRUCT<AgeYr varchar>)WITH (KAFKA_TOPIC='eip-legacy-13',VALUE_FORMAT='JSON' ); CREATE Stream StreamLegacyNa
浏览 1提问于2019-01-04得票数 2
我使用的是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
我正在尝试使用这里给出的例子在docker for windows (工具箱)上运行一个最小的融合社区示例：
但似乎所有组件都启动了，只有连接失败，其中一些组件无法工作，
这是我的docker-compose.yml
version: '2'
services:
zookeeper:
image: confluentinc/cp-zookeeper:6.1.1
hostname: zookeeper
container_name: zookeeper
ports:
- "2181:2181"
浏览 0提问于2021-03-30得票数 0
我有一张不足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
回答已采纳
使用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
回答已采纳
我有一个名为getCityStats(string，double string)的自定义UDF，它接受2个参数并返回一个JSON字符串(对象)数组，如下所示
{"zipCode":"90921"，“模式”：3.54} {"zipCode":"91029"，“模式”：7.23} {"zipCode":"96928"，“模式”：4.56} {"zipCode":"90921"，“模式”：6.54} {"zipCode":"91029"，“
浏览 0提问于2018-09-18得票数 0
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
回答已采纳
我有一个包含客户记录的卡夫卡主题，叫做“客户创造的”。每个客户都是该主题中的新记录。有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
回答已采纳
1回答
我使用汇合JDBC连接器将消息发布到主题中。源连接器将在每次轮询中向主题发送数据和架构。我想检索这个架构。
有可能吗？多么?有人能给我建议吗
我的目的是创建一个KSQL流或基于模式构建的KSQL流或表，由Kafka连接器进行投票。
浏览 0提问于2018-11-22得票数 2
回答已采纳
1回答
我正在寻找关于KSQL存储查询和表的位置的文档。例如，由于KSQL是为使用Kafka而构建的，因此当我从主题创建表时，或者当我编写查询时，表或查询结果存储在哪里？更具体地说，KSQL是使用某种类型的指针指向主题分区内的段内的事件，还是在我从主题创建表时复制事件？
浏览 12提问于2019-10-30得票数 1
回答已采纳
1回答
我们正在与KSQLDB一起执行POC，并有一些疑问：
我有一个名为USERPROFILE的卡夫卡主题，它有大约1亿张独特的记录和10天的保留政策。这个Kafka主题继续从其底层的RDBMS表接收实时插入/更新类型的事件。
以下是卡夫卡主题中收到的记录的简单结构：
{"userid":1001,"firstname":"Hemant","lastname":"Garg","countrycode":"IND","rating":3.7}
1.)我们已就上述主题开设了一
浏览 3提问于2021-05-27得票数 1
我们正在尝试将Kafka KSQL迁移到我们的系统中，并愿意分享一些我们在此过程中无法解决的问题。我们的集群中有3个Kafka节点，每个服务器都有：
8 CORE
50G+ RAM
100G ssd
在每台服务器上，我们都有zookeeper来管理集群。所有操作系统限制都会增加，以便节点可以使用比其所需更多的资源：
Xmx: 10G
Xms: 10G
nofiles: 500000
目前，从producer到集群的流量很小(大约每秒10条消息)。现在我们只有一个生产者，消息格式是：
{"user_id": <id|INT>, "actio
浏览 0提问于2018-08-24得票数 2
1回答
我正在编写这个卡夫卡流应用程序，它接收被注册在卡夫卡主题中的传感器读数(在JSON中作为消息)，并在每分钟、每小时和每天的基础上对这些读数的值执行一些聚合。然后，我将从这些聚合中派生的KTables具体化，并使用默认状态存储存储它们。我想知道是否可以使用KSQL查询这些表。
浏览 1提问于2019-10-01得票数 1
回答已采纳
1回答
我正试图在ksql cli中创建一个kafka流，并使用下面的ksql命令。从命令中可以看出，流的来源是kafka主题。
CREATE STREAM
TestStream
WITH
(
kafka_topic = 'testtopic',
value_format = 'PROTOBUF'
);
这个kafka主题，使用模式-注册表和原型格式。架构如下。
message TestSchema {
optional string deviceId = 1;
required bytes mac = 2;
optional uint32
浏览 1提问于2021-03-30得票数 1
我正在尝试使用运行在我的Windows 10机器上的docker容器中的ksqlDB连接到外部Oracle数据库。我已经阅读了ksqlDB网站上提到的教程，并设法使用下面的文件运行ksqlDB。现在，我需要创建JDBC连接器来连接到外部ORACLE数据库(而不是容器内)。由于大多数可用的教程都在Postgres数据库上运行在容器中，所以我对与外部数据库的连接感到有点困惑。下面我已经提到了连接器的一个模板。请建议如何根据我的Oracle数据库配置修改它？
假设Oracle数据库配置在我的本地计算机上如下所述：
HOST = dev-db.com
PORT = 1522
SERVICE NAME
浏览 2提问于2020-02-26得票数 0
回答已采纳
我无法启动。它提供了以下错误，
ksql-server-start: 14: Bad substitution
ksql-server-start: 32: exec: //bin/ksql-run-class: not found
动物园管理员和kafka服务器已成功启动。
任何建议都会有帮助
浏览 4提问于2020-07-31得票数 0
回答已采纳
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
我已经在KSQL中创建了一个流，如下所示。
<code>A0</code>
假设我有一个主题，其中包含流中的以下记录
<code>A1</code>
我尝试通过在KSQL中创建一个表来获取单个记录的计数，假设输出是
<code>A2</code>
我还尝试用流式应用程序代码而不是KSQL编写JAVA逻辑。但这将对较少的数据有所帮助。在未来，我们会得到超过100k的记录，那时所有这些迭代都需要花费很多时间，这会影响代码的速度。所以我想不要用这个。以下是代码
<code>A3</code>
<
浏览 31提问于2019-08-22得票数 0
我正在最新版本中的AWS EC2实例上测试ksqldb (合5.5.1)，并且有一个我无法解决的访问问题。
我有一个安全的Kafka服务器(SASL_SSSL，SASL模式平原)，一个不安全的架构注册表( Avro序列化程序的另一个问题，但暂时还可以)，以及一个安全的KSQL和客户端。
主题正确地填充了JDBC源连接器的数据(仅值，没有键)。当我在KSQL中列出主题时，I可以使用无问题的访问ksql，而无需问题。当我选择推送流时，当我按下某个主题时(在我的例子中是用Kafka )，我可以得到消息。<code>H 210</code><code>H 111&l
浏览 5提问于2020-09-02得票数 1
回答已采纳
我有一个现有的kafka经纪人:9092。该代理运行的是Apache Kafka版本2.2.0。我想使用ksqlDB对来自kafka broker上的主题的数据进行一些流处理。因此，根据https://docs.confluent.io/platform/current/installation/versions-interoperability.html的兼容性表，我使用的是Confluent Platform V5.2中的ksqlDB。 我在ksql/ksql-server.properties中设置了bootstrap.servers=<myurl>:9092。 但是，当我
浏览 43提问于2021-01-26得票数 0
回答已采纳
这是一个关于如何将自管理的ksqlDB / ksql服务器连接到汇合云的问题。
我有一个汇合的基本集群运行在在GCP亚洲南部。
在这个集群中，我希望将自管理的ksqlDB连接到聚合云控制中心。
下面是我从合流云复制的配置，并将其放入托管的ksqldb。
这个自管理的ksqldb是一个单机GCP计算单元。
下面的属性中也存在相同的配置。
/home/confluent/confluent-5.5.1/etc/ksqldb/ksql-server.properties
并且使用以下命令启动了ksql服务器。
nohup /home/confluent/confluent/
浏览 0提问于2020-09-07得票数 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
我在Json中有一个有50个字段的流式主题。我尝试使用主题中的KSQL创建另一个包含1个字段的流，如下所示：
create stream data (timeGMT string) with (kafka_topic='json_data', value_format='json');
已成功创建流，但以下KSQL查询未返回任何数据：
select * from data;
它在KSQL 5.0.0上运行
浏览 0提问于2019-01-24得票数 0
我确实配置了到数据库的连接，并在主题上配置了所有数据传输，因为当我运行使用者时，它会返回数据。
如何将此主题转换为表并在KSQL中持久化数据？
非常感谢
浏览 0提问于2018-10-11得票数 0
提供您正在运行的安装程序的详细信息让我们知道您正在运行的KSQL的版本、操作系统等，KSQL版本: confluent-ksql-5.3.1-1。概述你的问题，问你问题！KSQL无法连接到kafka，导致超时异常。
以下是ksql配置文件：
bootstrap.servers=hostname1:9093
listeners=http://0.0.0.0:8088
ksql.logging.processing.topic.auto.create=true
ksql.logging.processing.stream.auto.create=true
#ksql.schema.registry
浏览 52提问于2019-11-13得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
