腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何
从
Kafka
Streams
中
的
平面
api
数据
有效地
链接
groupby
查询
?
bigdata
、
apache-kafka-streams
我有一些来自
API
的
随机
数据
进入
Kafka
主题,看起来是这样
的
: {"vin": "1N6AA0CA7CN040747", "make": "Nissan", "model": "Pathfinder.filter((k,v)->v.getYear() > 2010)
浏览 24
提问于2021-08-12
得票数 0
回答已采纳
2
回答
Kafka
Streams
- java版本依赖关系
apache-kafka-streams
我正在使用Java1.6运行我
的
应用程序,并计划将一些方面与
Kafka
集成。 我正在探索是否应该使用
Kafka
Consumer (使用poll())或使用KafkaStreams
API
。我们需要Java 1.7 / 1.8来使用Stream
API
吗?
浏览 3
提问于2018-12-20
得票数 0
1
回答
Kafka
streams
协同分区与交互式
查询
apache-kafka
、
apache-kafka-streams
、
partitioning
状态存储是
从
第一个主题构建
的
,第二个流读取状态存储。当我启动拓扑时,我看到这些流线程被分配了两个源主题
的
相同分区(共同分区)。我假设这是因为状态存储被第二个主题流访问。对我来说,第二个主题应该尽可能快地处理。处理第一个主题
的
延迟是可以
的
。Since there is no co-partitioning, tasks has to use interactive
浏览 5
提问于2020-10-05
得票数 0
1
回答
Apache
Kafka
与HTTP
API
apache-kafka
我刚接触Apache
Kafka
和它
的
与
API
相关
的
流服务,但想知道是否有任何正式
的
文档来获取摄取所需
的
初始原始
数据
?
从
本质上讲,我想尝试构建一个初级
的
密码交易机器人,但我
的
印象是http
API
可能比与
Kafka
Streams
集成
的
API
具有更多
的
延迟。例如,我知道RapidAPI有一个可以访问
的<
浏览 0
提问于2021-06-05
得票数 0
1
回答
Rest
数据
摄取到
数据
湖
java
、
rest
、
apache-kafka
需求将
数据
摄取到
数据
湖
的
标准方法?满载、CDC和流
数据
。将
数据
加载到
kafka
主题中,不重复
浏览 0
提问于2018-01-30
得票数 1
2
回答
Apache Beam over Apache
Kafka
流处理
apache-kafka
、
apache-beam
、
apache-kafka-streams
、
stream-processing
Apache Beam和Apache
Kafka
在流处理方面有什么不同?我也在努力掌握技术和编程上
的
差异。 请通过您
的
经验报告来帮助我理解。
浏览 1
提问于2018-06-15
得票数 10
1
回答
使用
kafka
作为事件存储来补充事件源聚合
apache-kafka
、
cqrs
、
event-sourcing
越来越多
的
文章将
kafka
作为事件存储,并将其用于使用cqrs和事件源构建
的
应用程序
中
。
如何
在
kafka
(作为事件存储库)
查询
某个聚合
的
事件,以完成写入端
的
操作?
浏览 1
提问于2016-10-15
得票数 4
1
回答
Kafka
Streams
API
如何
从
模式注册表获取正确
的
模式?
apache-kafka-streams
、
confluent-platform
、
confluent-schema-registry
我试图理解
Kafka
Streams
API
是
如何
与Schema Registry一起工作
的
。我知道在设置应用程序时必须指定Schema Registry URL,但我无法理解如果不指定主题名称或ID,应用程序
如何
从
注册表检索正确
的
模式。 它使用主题名称检索模式?
浏览 2
提问于2019-11-25
得票数 2
1
回答
在这个例子中使用
Kafka
有什么意义,为什么不直接使用DB呢?
apache-kafka
、
architecture
这是一个卡夫卡应该
如何
运行一个社交网站
的
例子。但我很难理解卡夫卡在这里
的
意义。我们不想储存在卡夫卡
的
帖子和喜欢,因为他们将在一段时间后被摧毁。因此,卡夫卡应该是视图和DB之间
的
中间存储。我想我们可以使用
kafka
作为某种缓存,以便
数据
在
Kafka
中
积累,然后我们可以在一个大
的
批处理
查询
中将其插入DB。但我很肯定这不是卡夫卡来这里
的
原因。
浏览 4
提问于2022-08-10
得票数 0
1
回答
KafkaStream.KTable
如何
用(压缩) KV格式将
数据
写入卡夫卡主题
java
、
apache-kafka
、
apache-kafka-streams
在
Kafka
(0.11.0.1)流
中
,一个演示应用程序final SerdewordCounts.to(stringSerde, longSerde, "
streams
-wordcount-output");
stream
浏览 3
提问于2017-09-21
得票数 0
1
回答
如何
使用KTable
从
kafka
1.1.0获取最新值
apache-kafka
、
apache-kafka-streams
当需要时,我想从这个主题中获取给定机器
的
最新连接信息。使用KTable可以做到这一点吗?如果是,请举例说明。我使用
的
是
kafka
1.1.0
浏览 0
提问于2019-07-17
得票数 0
1
回答
通过MongoDB使用Storm bolt或Spark-streaming丰富
数据
mongodb
、
apache-kafka
、
spark-streaming
、
apache-storm
我想创建一个Storm Spout,它从Apache
Kafka
的
主题中读取
数据
,并将这些
数据
发送到连接到MongoDB
的
Storm bolt,并
查询
我
从
Kafka
收集
的
消息以丰富
数据
。例如:我有一个personID (我是通过
Kafka
发来
的
消息得到
的
),我想使用这个personID
查询
MongoDB
中
的
个人
浏览 0
提问于2018-04-18
得票数 0
1
回答
Kafka
Streams
DSL进程方法是
如何
工作
的
?
apache-kafka
、
apache-kafka-streams
我一直在使用
Kafka
Streams
,并获得了一些基本
的
功能,但我在理解
Kafka
Streams
DSL
中
的
process方法时遇到了一些问题。具体地说: 我知道有两种使用
Kafka
Streams
的
方法,低级处理
API
和高级
Streams
DSL。对于较低
的
级别,您可以更明确地定义拓扑,命名每个节点等,而流DSL则将大部分抽象出来。然而,高级流DS1具有称为
浏览 9
提问于2020-01-20
得票数 0
回答已采纳
6
回答
Kafka
Streams
:流式计算、
Kafka
Streams
的
特点和架构是什么?
api
Kafka
在0.10版本推出了Stream
API
,提供了对存储在
Kafka
内
的
数据
进行流式处理和分析
的
能力。小白一名,各位大佬能给我解释一下流式计算、
Kafka
Streams
的
特点和架构吗?谢谢!
浏览 2070
提问于2018-09-14
1
回答
跨
Kafka
分区对消息进行排序,并将其放入另一个
Kafka
主题中
java
、
apache-kafka
、
apache-kafka-streams
如何
对所有分区
中
的
所有消息进行排序(基于ts),并将其放入Y partitions (Y < X,其中Y也可以为1)
的
新主题中? 在此操作过程
中
,不会向原有的
Kafka
主题添加新
的
数据
。我试图避免将所有
数据
缓冲到临时
数据
存储中进行排序。因此,基本上我正在寻找一个关于流
数据
的
X-Way merge。有没有人可以让我知道,在java中使用
Kafka
St
浏览 25
提问于2020-01-18
得票数 1
1
回答
Kafka
流读写以分离集群
apache-kafka
、
apache-kafka-streams
以前也回答过类似的问题,但是这个解决方案对我
的
用例不起作用。最终,我们将用德鲁伊对卡夫卡主题
数据
进行索引。不可能运行单独
的
Dr
浏览 1
提问于2019-11-15
得票数 0
回答已采纳
2
回答
如何
在
Kafka
中进行转换(PostgreSQL-> Red shift )
postgresql
、
apache-kafka
、
amazon-redshift
我对
Kafka
/AWS.My
的
数据
从
几个来源加载到DW(Redshift)
的
要求是新
的
。 我
的
消息来源之一是PostgreSQL。我发现一个使用卡夫卡将
数据
同步到红移
的
。本文更好地同步了PostgreSQL与redshift.But之间
的
数据
,我
的
要求是在加载到Redshift之前转换
数据
。有人能帮我
如何
转换
Kafka
浏览 0
提问于2018-02-19
得票数 1
回答已采纳
1
回答
更好
的
以事件为中心
的
方式来解决卡夫卡或任何流媒体服务
中
的
请求应答问题
http
、
apache-kafka
、
microservices
在微服务体系结构中使用
Kafka
时,我陷入了一个问题。我无法理解处理HTTP请求
的
微服务
如何
能够向用户发送响应。我希望
从
HTTP获取
数据
,然后将其发布到名为A
的
主题中,然后另一个验证器服务将验证它,并将其发布到另一个主题B上。我希望
从
主题B
的
订阅
数据
中将处理过
的
数据
发送到HTTP响应。
浏览 8
提问于2022-02-17
得票数 1
回答已采纳
1
回答
将Ktable按键分组后无效(负)时间戳
apache-kafka
、
apache-kafka-streams
问题是压缩后
的
主题被写入到使用流主题
的
不同分区器
中
,因此联接无法按预期工作(一些键不匹配,因为它们位于不同
的
分区
中
)。 输入记录ConsumerRecord(主题=映射可能是因为在没有嵌入时间戳
的
情况下,使用了预0.10生产
浏览 1
提问于2019-08-28
得票数 0
回答已采纳
1
回答
如何
在没有卡夫卡连接水槽
的
情况下将卡夫卡
的
数据
输入商店?
apache-kafka
、
apache-kafka-connect
当阅读关于
Kafka
以及
如何
从
Kafka
获取
数据
到适合特定任务
的
可
查询
数据
库时,通常会提到
Kafka
连接汇。如果我需要卡夫卡搜索像ElasticSearch这样
的
索引,或者像Hadoop这样
的
分析工具,只要有一个卡夫卡连接
的
水槽,这听起来就像是要走
的
路。但我
的
问题是,处理一个不那么流行
的
商店
的
最佳方法是什么,比
浏览 0
提问于2019-06-23
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Kafka streams概览
初探Kafka Streams
KSQL:Apache Kafka的开源Streaming SQL引擎
Kafka Streams与Quarkus:实时处理事件
kafka sql入门
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券