腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
KSQL
说,它希望现有的主题有
两个
分区(主题有
一个
),
apache-kafka
、
ksqldb
、
confluent-platform
当试图
从
现有的Kafka主题创建
KSQL
中
的
Stream时,我面临以下错误。io.confluent.
ksql
.exception.KafkaTopicExistsException:名称为“ -data”的卡夫卡主题已经存在,具有不同
的
分区/副本配置。
KSQL
需要
两个
分区(主题有
一个
)和
一个
复制因子(主题有
一个
)。 在
KSQL
中
创建
流</em
浏览 1
提问于2019-11-13
得票数 1
1
回答
从
两个
ksql
流
中
获取
一个
带有
值
的
ksql
流
ksqldb
我创建了
一个
值
为数组
的
主流。我会在1处
获取
数组字段,并将其流式传输到ne
ksql
流
。DatBetrZ.BetrZStdOM","value":[19.737154,512.0,320.18024,423.87027,399.99384,292.1198,450.821]} 然后,我创建
一个
新
的
流来
获取
一个
数组字段KNIFE02":512.0,"KNIFE03&quo
浏览 19
提问于2019-05-08
得票数 1
回答已采纳
1
回答
KSQL
:在尝试
从
流
中选择*时发生杰克逊错误
ksqldb
这个问题基于
中
的
解决方案路径--当我尝试从
一个
主题创建
的
带有
value_format='json'
的
流
中
获取
一个
错误时,我会得到
一个
错误。我仍然可以print底层
的
主题,但是执行select * from stream;会引发
一个
错误。这是我如何创造这个问题..。[
浏览 2
提问于2019-11-14
得票数 0
1
回答
带有
破折号(-)
的
ksql
json字段名
json
、
apache-kafka
、
confluent-platform
、
ksqldb
我
的
JSON
中
的
一个
字段名是“”。当我尝试创建
一个
具有该字段名
的
流
时,
KSQL
不喜欢这个破折号。我试过单引号,双引号,用不同
的
方式逃避--没有运气。如何
从
主题中
的
json
获取
该字段,使其处于
KSQL
流
中
?下面是我
的
一些尝试
的
日志:
ksql
> create stream
浏览 0
提问于2018-11-02
得票数 2
回答已采纳
1
回答
KSQL
查询线程号
ksqldb
是否有一种方法来指定运行在
KSQL
上
的
KSQL
查询应该使用
的
线程数?换句话说,查询
的
并行性。 在
KSQL
上可以运行
的
应用程序数量是否有任何限制?何时或如何决定扩大规模?
浏览 1
提问于2019-07-07
得票数 2
回答已采纳
1
回答
KSQL
是在幕后发出远程请求,还是
一个
表实际上是
一个
全局KTable?
apache-kafka-streams
、
ksqldb
并不陌生,但我
的
理解是,
KSQL
构建在Kafka
流
之上,并且每个
ksql
-server实例大致等同于Kafka
流
应用程序实例。我注意到
的
第一件事是,一旦我启动了
ksql
-server
的
新实例,它就已经知道在第
一个
实例上创建
的
表/
流
,尽管它是开发人员模式下
的
交互式实例。第二,我可以根据来自(
两个
实例)
的
ID来选择同
一个
客
浏览 1
提问于2019-08-02
得票数 1
回答已采纳
2
回答
如何
从
kafka流到cassandra和递增计数器
apache-spark
、
cassandra
、
apache-kafka
、
apache-kafka-connect
我有apache访问日志文件,我想在cassandra表
中
存储每个页面的访问计数(总数/每天/每小时)。 我正在尝试使用kafka连接
从
日志文件流到kafka主题。为了在Cassandra
中
增加指标计数器,我可以再次使用Kafka Connect吗?
浏览 0
提问于2017-10-11
得票数 0
1
回答
如何在
KSQL
中加入此表?
apache-kafka
、
confluent-platform
、
ksqldb
我正在使用CDC和Debezium连接器将
中
的
几个表流到Kafka。其中
一个
SQL表在
KSQL
中表示为
流
,其余
的
是我希望加入到
流
中
以丰富数据
的
KSQL
表,因此我有
一个
KSQL
流
链,每个表都将
一个
新
的
KSQL
表连接到该链
中
前
一个
KSQL
流
<e
浏览 0
提问于2019-08-09
得票数 0
2
回答
如何
从
具有组合键
的
主题创建
KSQL
表?
apache-kafka-connect
、
ksqldb
、
confluent-platform
我有一些
带有
字段stringA stringB
的
主题数据,我只是想在从主题创建
KSQL
表时将其用作键。
浏览 1
提问于2020-01-08
得票数 0
3
回答
如何加入多个卡夫卡主题?
apache-kafka
、
apache-kafka-streams
、
ksqldb
具有通用应用程序日志(log4j)
的
第
一个
主题。存储诸如HTTP请求/响应和警告、异常等.可以有多个日志与
一个
逻辑业务请求相关联。(这些日志在几秒钟内就会发生) 因此,单个逻辑业务请求可以有多个日志、命令和事件,这些日志、命令和事件由微服
浏览 0
提问于2018-03-11
得票数 6
2
回答
ksql
-有可能从多个主题创建
流
并获得完整
的
事件有效负载吗?
apache-kafka
、
ksqldb
我们需要监听多个主题,并在每个主题
的
事件
中
查找特定
的
字段。每个主题事件都是json格式
的
,并且要求json格式
的
固定字段很少。需要从所有这些多个主题中筛选事件,并在每个事件有效负载
中
查找特定字段。如果此字段
值
与特定格式匹配,则将这些来自不同主题
的
事件发送到
一个
固定主题,该主题可由另
一个
使用者进一步处理。我正在寻找
ksql
是否可以在这种情况下有所帮助-我们
从
多个主题创建
一个<
浏览 2
提问于2018-10-30
得票数 0
1
回答
我可以使用
KSQL
来生成处理超时吗?
apache-flink
、
apache-kafka-streams
、
ksqldb
我正在尝试使用
KSQL
在
一个
时限内进行任何处理,并在那个时间限制
中
得到结果。请参阅“处理时间定时器”下面的,以获得使用Apache演示
的
相同想法。给予:
一个
下游处理器,它希望在事务出现在第
一个
流
中
之后,在
一个
特定
的
超时(例如20秒)
中
接收更新
的
浏览 1
提问于2018-11-14
得票数 1
回答已采纳
1
回答
为什么当
从
v0.6.0升级到v0.8.1时,ksqldb-server会崩溃?
apache-kafka
、
confluent-platform
、
ksqldb
我有
一个
现有的ksqldb服务器,我想将它从以连接作为分离节点
的
v0.6.0升级到
带有
嵌入式连接
的
v0.8.1。(KsqlServerMain.java:75)这里
的
关键信息是:未识别的字段"useOffsetAsQueryID“(未标记为可忽略
的
类useOffsetAsQueryID(4个已知属性
浏览 2
提问于2020-04-07
得票数 1
回答已采纳
1
回答
如何在
ksql
中
获取
ktable
中
不同记录
的
总计数
apache-kafka
、
apache-kafka-streams
、
ksqldb
我已经在
KSQL
中
创建了
一个
流
,如下所示。<code>A0</code><code>A1</code><code>A2</code>我还尝试用流式应用程
浏览 31
提问于2019-08-22
得票数 0
1
回答
在ksqlDB
中
创建
的
流
显示为空
值
apache-kafka
、
confluent-platform
、
ksqldb
我正在尝试在ksqlDB
中
创建
一个
流
,以便
从
kafka主题中
获取
数据并对其执行查询。(KAFKA_TOPIC='public.location', PARTITIONS=10); 主题public.location
中
的
数据是,在创建
的
流上执行SELECT,我在输出
中
得到NULL。|Query te
浏览 14
提问于2021-07-28
得票数 2
回答已采纳
1
回答
ksql
-接收器主题XXXX在元存储
中
不存在
apache-kafka
、
ksqldb
我正在尝试在基于sourceTopic1和sourceTopic2
的
targetTopic1
中
创建数据。这
两个
源主题应该具有相同
的
事件结构。首先创建目标
流
,然后尝试
从
另
一个
源流向当前
流
插入数据。
ksql
> CREATE STREAM sourceTopic1Stream (category varchar, source varchar, type varchar, id varchar, payload%'; M
浏览 3
提问于2018-11-06
得票数 1
1
回答
在执行连接时,在
KSQL
中使用自定义列或除rowtime列以外
的
其他列作为时间戳列
ksqldb
、
confluent-platform
您好,我正在试用
KSQL
,发现大多数文档都提供了与kstream或ktable直接连接
的
示例。假设我已经由团队X创建了
两个
流
,并且我不能更改它或重新创建新
的
流
,并且还想使用现有的
流
。是否有其他方法可以将现有
流
中
的
rowtime列指定为时间戳列,并考虑其在
KSQL
中
的
连接时间窗口。
浏览 0
提问于2019-09-03
得票数 0
1
回答
如何将结构化记录直接
从
KSQL
接收到连接器(例如,InfluxDB)
apache-kafka
、
ksqldb
、
confluent-platform
我正在尝试将数据直接
从
KSQL
接收到InfluxDB (或任何其他需要定义
的
连接器)。我能够让事情在简单
的
情况下工作,但是当模式需要复杂
的
类型时,我就开始有麻烦了。(即InfuxDB
的
标签)。AVRO模式并从
一个
简单
的
生产者
中
填充记录,我就可以通过入门指南并嵌入InfluxDB
的
标记。但是,当我转到
KSQL
时,如果我试图将AVRO
流
直接沉入InfluxDB,就会丢失有关复杂类型(标
浏览 1
提问于2020-05-28
得票数 1
1
回答
ksql
中
的
可变长度列表
list
、
apache-kafka
、
ksqldb
在
KSQL
中
,可以将EXTRACTJSONFIELD用于嵌套结构,但我不知道如何处理可变长度列表。例如:我可以将quux作为基本
流
的
varchar来处理, create streamkafka_topic='mytopic',
浏览 1
提问于2018-06-09
得票数 0
回答已采纳
1
回答
将自管理ksqlDB连接到合流云管理
的
ksql
服务器
confluent-platform
、
ksqldb
、
confluent-cloud
、
confluent-control-center
这是
一个
关于如何将自管理
的
ksqlDB /
ksql
服务器连接到汇合云
的
问题。在这个集群
中
,我希望将自管理
的
ksqlDB连接到聚合云控制中心。下面是我
从
合流云复制
的
配置,并将其放入托管
的
ksqldb。这个自管理
的
ksqldb是
一个
单机GCP计算单元。下面的属性
中
浏览 0
提问于2020-09-07
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
kafka sql入门
KSQL:Apache Kafka的开源Streaming SQL引擎
基于Kafka技术栈构建和部署实时搜索引擎的实践
【大数据】KSQL初体验
Kafka怒改开源协议,不想云厂商坐收渔翁之利
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券