腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
您
可以
在
KSQL
中
为
表
指定
嵌套
键
吗
?
ksqldb
我试图从一个带有对象
键
的主题创建一个
表
,但
KSQL
无法识别该变量。 有什么解决方案
吗
?
浏览 13
提问于2019-05-24
得票数 3
1
回答
KSQL
:
表
键
列不是联接条件中使用的列
apache-kafka
、
confluent-platform
、
ksqldb
我想在与
键
不同的列上加入两个具有一对多关系的
KSQL
表
。我将给出一个例子,一个上下文,一个我开始研究的解决方案,以及我遇到的问题。创建两个连接器,并创建两个
KSQL
表
(从现在起,所有命令都在
KSQL
中
):SEL
浏览 3
提问于2020-02-18
得票数 0
1
回答
KSQL
表
中
怎么会有重复的in?
apache-kafka
、
confluent-platform
、
ksqldb
我
在
主题之外创建了一个流,并重新设置了它的键值,因为
键
为
空。 在这个新主题的基础上,我创建了一个
表
。我们的目标是拥有一个不断更新的对象
表
(这里是类别)。
ksql
> select * from categories; 1568287458487 | 1 | 1 | Beverages | Soft drinks, coffees, teas, beers> postgres
中
的Categories
表
: CREATE TABLE catego
浏览 26
提问于2019-09-12
得票数 1
回答已采纳
1
回答
如何在
KSQL
中加入此
表
?
apache-kafka
、
confluent-platform
、
ksqldb
我正在使用CDC和Debezium连接器将
中
的几个
表
流到Kafka。其中一个SQL
表
在
KSQL
中表示
为
流,其余的是我希望加入到流
中
以丰富数据的
KSQL
表
,因此我有一个
KSQL
流链,每个
表
都将一个新的
KSQL
表
连接到该链
中
前一个
KSQL
流的输出。让A是一个
KSQL
流。 设B到D是
KSQL
浏览 0
提问于2019-08-09
得票数 0
1
回答
架构注册
表
安全配置
apache-kafka
、
confluent-schema-registry
、
apache-kafka-security
已尝试使用SSL配置架构注册
表
。尝试将HTTPS架构注册
表
与AVRO Producer一起使用时,失败并显示错误我已配置
为
忽略主机名检查。但还是不起作用。类似的配置
在
KAFKA REST、CONNECT和
KSQL
上也有效。listeners=https://0.0.0.
浏览 5
提问于2020-05-12
得票数 0
1
回答
在
ksql
中转换数据
apache-kafka
、
transform
、
ksqldb
payload_transform = { 'b' : 'b1' 'c' : 'a1'考虑到数据(payload)来自卡夫卡,我想看到payload_transform
在
消费者身上的转换有可能用
ksql
吗
?更新:payload = { 'b' :
浏览 0
提问于2018-03-21
得票数 1
回答已采纳
2
回答
在
docker
中
运行
ksql
的问题
apache-kafka
、
confluent-platform
、
confluent-schema-registry
、
ksqldb
我
在
Kubernetes集群的容器
中
运行了confluent kafka、zookeeper、schema-registry和
ksql
。Kafka,zookeeper和模式注册表工作得很好,
可以
创建主题并以Avro格式写入数据,但当我尝试使用curl检查
ksql
并创建一些流时,例如: curl -XPOST http://
ksql
-svc.someapp:8080/
ksql
-H "Content-Type: applicatio
浏览 0
提问于2018-03-18
得票数 0
1
回答
Kafka
键
格式
apache-kafka
、
apache-kafka-streams
、
ksqldb
我的主题之一有一个字符串-json作为
键
{“城市”:“X”,"id":22}。
在
我的
ksql
语句中,我想将它提取到两个不同的字段,而不是一个,这样以后我就
可以
过滤并加入。
在
文档
中
,它似乎允许我只将整个字符串插入
键
中
,而不是允许将其格式化为JSON (就像FORMAT_VALUE一样),请参见下面.对此有什么建议
吗
?VALUE_FORMAT (必需)
指定
主题中消息值的序列化格式。支持的格式: JSO
浏览 2
提问于2018-04-15
得票数 1
回答已采纳
2
回答
如何从具有组合
键
的主题创建
KSQL
表
?
apache-kafka-connect
、
ksqldb
、
confluent-platform
我有一些带有字段stringA stringB的主题数据,我只是想在从主题创建
KSQL
表
时将其用作
键
。
浏览 1
提问于2020-01-08
得票数 0
1
回答
KSQL
代码工作,但是创建
表
`.‘因为SELECT代码返回错误- io.confluent.
ksql
.util.KsqlStatementException:列无法解析
confluent-platform
、
ksqldb
我在用
KSQL
创建
表
或流时遇到了问题。 FROM pageviews_enriched GROUP BY regionid;我试着
在
指挥舞会上运行20 SECONDS)GROUP BY "computer" 但是,当我尝试根据这
浏览 3
提问于2019-11-07
得票数 0
1
回答
如何获取基于连接器名称的Kafka源连接器模式
apache-kafka
、
apache-kafka-connect
、
confluent-platform
、
confluent-schema-registry
、
ksqldb
源连接器将在每次轮询
中
向主题发送数据和架构。我想检索这个架构。我的目的是创建一个
KSQL
流或基于模式构建的
KSQL
流或
表
,由Kafka连接器进行投票。
浏览 0
提问于2018-11-22
得票数 2
回答已采纳
1
回答
如何从kafka
中
的主题创建大量JSON字段的?
apache-kafka
、
confluent-platform
、
ksqldb
"GlossSee": "markup" } }并希望从kafka主题创建流,所有字段都不需要
指定
KSQL
中
的每个字段,例如:(kafka_topic='pageviews', value_format='JSON
浏览 1
提问于2018-10-01
得票数 5
回答已采纳
1
回答
使用ksqlDB SInk连接器处理JDBCv0.11组合
键
(
表
)以
在
MySQL
中
复制
apache-kafka
、
confluent-platform
、
ksqldb
我使用的是ksqlDB版本0.11 (目前不能升级到较新的版本),并且愿意使用JDBC Sink connector将
表
数据复制到MySQL
中
。ksqlDB 0.11版本不支持多个
表
键
,我的数据需要使用多个GROUP BY表达式进行分组。,两个主键(stid和asig)已经合并到一个名为
KSQL
_COL_0的字段
中
,这是Version0.11的预期行为。_0,以便告诉JDBC stid和asig都是MySQL
表
中
的主键。你有什么办法来管理它
吗<
浏览 46
提问于2021-05-22
得票数 0
回答已采纳
1
回答
KSQL
查询未通过REST API返回响应,即使我正在使用LIMIT子句
apache-kafka
、
ksqldb
即使我使用了limit子句,
KSQL
查询也没有通过REST API返回响应。我的主题包含1000条记录,我已经
在
它上面创建了一个流。为了通过REST
指定
limit子句,我们应该提前知道记录数
吗
?它是如何工作的? 我尝试过使用邮递员、curl选项,但这些选项都不起作用。但是,从
ksql
-cli
可以
很好地执行相同的查询。EndPoint
为
/query。{ "
ksql
":"SELECT * FROM SAMPLE_TO
浏览 0
提问于2019-06-18
得票数 1
1
回答
使用Kafka Connect读取AVRO编码消息(由
KSQL
流创建)的问题
apache-kafka
、
apache-kafka-connect
、
confluent-schema-registry
、
ksqldb
Data transforms 由于我们的内部系统需要用AVRO编码数据,我们创建了一个
KSQL
集群,通过
在
KSQL
中
创建以下流将传入的数据转换为AVRO: "
ksql
": "然后我们
在
一个(新的) Kafka集群
中
创建一个Kafka连接器。
在
某些上下文中,我们使用多个Kafka Connect集群(这些集群具有相同的属性),因此我们
为
这些数据运行了Kafka Connect集群,但对于其他A
浏览 1
提问于2019-10-31
得票数 0
回答已采纳
3
回答
如何加入多个卡夫卡主题?
apache-kafka
、
apache-kafka-streams
、
ksqldb
存储诸如HTTP请求/响应和警告、异常等.
可以
有多个日志与一个逻辑业务请求相关联。(这些日志在几秒钟内就会发生) 流媒
浏览 0
提问于2018-03-11
得票数 6
1
回答
KSQL
选择删除事件
c#
、
apache-kafka
、
kafka-consumer-api
、
ksqldb
如果在用户主题中插入/更新了新消息,我将在Ktable
中
获得新记录,并引发事件。如果我发送一个带有墓碑的密钥到用户主题,Ktable
中
的记录会被删除,但我的consumer..below
中
没有任何事件是代码,我如何监听Ktable事件。\"}}", Encoding.UTF8, "application/vnd.
ksql
.v1+json"); //request.Content.Headers.Add("Acc
浏览 10
提问于2019-09-24
得票数 0
1
回答
KSQL
:我
可以
在
KSQL
函数中使用线程来加快进程
吗
?
java
、
apache-kafka
、
user-defined-functions
、
ksqldb
我
在
3个节点上运行独立的
ksql
-server,与一个由3节点组成的Kafka集群进行对话。从Stream创建了一个具有15个分区的Topic,数据
在
流中进行了一些充实。; @UdfDescription(name = "Ip2Lookup", description
在
该方法上设置synchronized后,每个
ksql
-server节点的速度
为</e
浏览 0
提问于2019-04-10
得票数 1
回答已采纳
1
回答
confluent-4.1.1是否支持带有
ksql
cli的
嵌套
avro?
apache-kafka
、
avro
、
confluent-schema-registry
、
ksqldb
我正在使用
ksql
cli开发confluent-4.1.1。我是否
可以
在此版本
中
创建
嵌套
avro数据格式的流,就像我
在
版本5
中
尝试的那样,它工作得很好,但在confluent-4.1.1
中
提到的
嵌套
avro模式
中
找不到有用的链接获取错误- 无法从架构注册
表
获取AVRO架构。
浏览 0
提问于2018-10-16
得票数 0
1
回答
合流4.1.0 ->
KSQL
:流
表
连接->
表
数据null
apache-kafka
、
ksqldb
key.separator=:" \ --from-beginning创建以下流和
表
并运行联接查询。
KSQL
: CREATE STREAM SAMPLE_STREAM (DEAL_ID VARCHAR, DEA
浏览 0
提问于2018-04-30
得票数 5
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
KSQL:Apache Kafka的开源Streaming SQL引擎
基于Kafka技术栈构建和部署实时搜索引擎的实践
kafka sql入门
【大数据】KSQL初体验
深入理解Kafka Connect:转换器和序列化
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券