腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
将Ktable按键分组后无效(负)时间戳
、
我正在
使用
KakfkaStreams (2.3.0)来
使用
流
和Ktable (压缩主题)之间
的
连接来丰富价值。问题是压缩后
的
主题被写入到
使用
流
主题
的
不同
分区器
中
,因此联接无法按预期工作(一些键不匹配,因为它们位于
不同
的
分区
中
)。 代理版本为0.10.2。我开始研究如何重新划分压缩
的
主题,方法是
使用
一个groupBy(),后面跟着
浏览 1
提问于2019-08-28
得票数 0
回答已采纳
2
回答
Kafka
stream vs
kafka
消费者如何决定
使用
什么
、
、
我做过一些
Kafka
流
应用程序和
Kafka
消费者应用程序。归根结底,
Kafka
流
只是消费者,它消费来自
Kafka
的
实时事件。所以我不知道什么时候
使用
Kafka
streams
,或者为什么我们应该
使用
Kafka
streams
,因为我们可以在消费者端执行所有的转换。我想了解
Kafka
stream和
Kafka
consumer之间
浏览 4
提问于2019-12-04
得票数 4
1
回答
IOError(Stalefile)异常由
Kafka
Streams
RocksDB引发
、
、
、
在运行有状态
的
Kafka
流
应用程序时,我遇到了各种
不同
的
RocksDB磁盘I/O Stalefile异常。只有当我至少有一个KTable实现并且发生在
不同
的
时间时,异常才会发生。(RocksDbStore.
java
:301)引起
的
Caused by: org.apache.
kafka
.
streams
.errors.ProcessorStateException: Error(RocksD
浏览 1
提问于2021-09-17
得票数 0
1
回答
Spring
Kafka
Streams
:缺少类型信息
我已经设置了一个简单
的
Kafka
流
Spring启动应用程序。Spring boot正在
使用
AutoConfiguration为卡夫卡
创建
工厂。消息是没有消息键
的
Json消息。
使用
下面的配置会导致在headers
中
显示No Type information消息。有什么建议吗?(SourceNode.
java
:63) ~[
kafka
-
streams
-2.0.1.jar:?]at org.apache.<
浏览 155
提问于2019-03-20
得票数 1
回答已采纳
1
回答
Sprint Cloud -
Kafka
Streams
绑定器-测试KafkaStreamsProcessor
、
KeyValue<>(key, outputMessage); } cloud:
kafka
: binder: - ${NX_
KAFKA
_SERVERS} content-type: applica
浏览 6
提问于2020-10-09
得票数 0
回答已采纳
1
回答
作为ETL替代品
的
Kafka
流媒体
的
最佳实践是什么?
我是卡夫卡
的
新手,目前我正在研究卡夫卡
流
,尤其是加入两个
流
。在我
的
示例
中
,我为每个对象
创建
了一个主题,并将对象(Vertrag,现金
流
)发送给每个对象。
浏览 1
提问于2019-06-16
得票数 0
1
回答
java
.lang.IllegalStateException:这不应该发生,因为只有在处理记录时才应该调用headers()
启动
流
应用程序(
使用
卡夫卡
流
)失败时
使用
"
java
.lang.IllegalStateException:这不应该发生,因为headers()应该只在处理记录时调用“有人知道为什么会发生这种事吗?(SourceNode.
java
:87) at org.apache.
kafka
.
streams
浏览 0
提问于2019-05-29
得票数 1
1
回答
我如何为变压器建立一个国家商店
我正在尝试
创建
一个转换器,并且在初始化它
的
StateStore时遇到了问题。我看了一下
中
的
例子,这是有意义
的
,但我正在尝试一些
不同
的
东西: Stores.persistentKeyValueStoreStore键,
使用
KeyValue作为Store值。我之所以问这个问题,是因为当包含“我
的
变压器”
的
<e
浏览 2
提问于2018-05-26
得票数 0
1
回答
卡夫卡流在StreamTask内部解码时间戳元数据时失败
、
在启动应用程序时,在
Kafka
流上出现了一些奇怪
的
错误。at org.apache.
kafka
.
streams
.processor.internals.StreamThread.run(StreamThread.
java
:671) 因此,出现了关于失败
流
的
错误额外信息:我们
的
应用程序
使用
kafka
流
,并
使用
相同
的
application.id和state.dir (
浏览 1
提问于2020-04-01
得票数 3
回答已采纳
1
回答
Hadoop可以做流媒体吗?
、
、
、
、
有人建议Hadoop做流媒体,并引用了Flume和
Kafka
作为例子。 虽然我知道它们可能具有流媒体功能,但我想知道它们是否可以与Storm/Spark/Flink等流处理技术并驾齐驱。
Kafka
是一个“发布-订阅模型消息传递系统”,而Flume是一个数据摄取工具。即使它们与hadoop交互/集成,从技术上讲,它们是“hadoop”本身
的
一部分吗?PS:我知道有一个是完全
不同
的
事情。
浏览 4
提问于2018-04-07
得票数 0
1
回答
卡夫卡流连接表太大
、
、
、
我想
使用
在KStream上执行一个左联接,并
使用
一个KTable将表
的
一些字段添加到
流
中
。 对于包含所有相关条目的表
的
更小版本(大约1,300项),一切都很好。一旦我
使用
了整个表(大约200,000个条目),就会在行
中
得到一个NullPointerException,其中包含KTable
的
Avro (GenericRecord)
的
相关字段。当我在KSQL
中
执行相同
的
左联接操作时,表
浏览 0
提问于2019-08-08
得票数 0
2
回答
来自单个主主题
的
多个
流
、
、
如何从一个主主题生成多个
流
?当我做这样
的
事:
streams
.start();org.apache.
kafka
.
streams
.errors.TopologyBuilderExceptionat o
浏览 5
提问于2017-02-23
得票数 14
回答已采纳
1
回答
Nodejs avro序列化不带模式注册表,然后在
Kafka
流
中
反序列化
、
、
、
我正在学习如
何在
没有模式注册
的
情况下
使用
nodejs执行Avro数据
的
序列化,将其发布到
Kafka
集群,然后在
Kafka
Streams
(
Java
)
中
检索它。在javascript方面,我尝试
使用
kafka
节点和avsc进行序列化。在
Kafka
流
中
,我决定实现一个自定义Serde,因为据我所知,由
Streams
API提供<e
浏览 3
提问于2020-03-06
得票数 0
回答已采纳
1
回答
如
何在
Java
中
使用
Kafka
Streams
创建
不同
的
流
?
、
、
我正在尝试从
Kafka
Java
中
的
KStream
创建
一个“
不同
”
的
流
。 我有一个输入流,其中
的
值是一组Double V0…Vn。输出
流
应计算V0 - 0、V1 - V0、V2 - V1…之间
的
差异Vn -Vn-1。我
的
第一个想法是这样做: KStream<String, Double> stream = builder.stream(TOPIC) K
浏览 10
提问于2019-07-03
得票数 0
回答已采纳
1
回答
如
何在
运行时根据一些值字段
创建
Kafka
主题名称
、
因此所有具有相似字段值
的
records<K,V>都放在Topic_<Field>
中
。如何
使用
kstream完成此操作?
浏览 2
提问于2018-05-23
得票数 1
2
回答
如何删除GlobalKTable存储
的
状态?
、
在应用程序启动时运行KafkaStreams.cleanUp() 向我
的
流
生成'Test: null‘消息,因为应该将空值视为存储
中
的
DELETE语句,正如所描述
的
。但是,我
的
流
应用程序失败了,因为空值不能反序列化为LONG。at org.apache.
kafka
.
streams
.processor.internals.RecordDeserializer.deserialize(RecordDeserializer.<
浏览 0
提问于2018-03-09
得票数 2
2
回答
Apache Beam over Apache
Kafka
流
处理
、
、
、
Apache Beam和Apache
Kafka
在
流
处理方面有什么
不同
?我也在努力掌握技术和编程上
的
差异。 请通过您
的
经验报告来帮助我理解。
浏览 1
提问于2018-06-15
得票数 10
1
回答
加入Redis
streams
、
我对Redis
streams
非常感兴趣。(看起来有可能构建由append-log驱动
的
小型系统,
如
Kafka
,但没有
Kafka
的
所有开销。)它看起来很简单,可以通过XADD访问日志/
流
,并
使用
日志/
流
中
的
条目。但是如果你想跨两个
流
加入呢?
Kafka
Streams
、Flink、Spark等提供了这样做
的
方
浏览 12
提问于2019-03-23
得票数 6
1
回答
获取
Kafka
Stream in process()方法
、
、
、
、
我正在做一个POC来演示一些Spring Cloud
Kafka
功能。我
使用
的
是带有SpringBoot 2.4.1
的
Java
11。我
的
build.gradle具有以下库 implementation 'org.springframework.cloud:spring-cloud-stream&
浏览 0
提问于2021-01-30
得票数 0
1
回答
Kafka
Streams
| RocksDB异常
、
、
应用
使用
kafka
版本为2.7.0Exception in thread "Average-3ded0155-d697-492
浏览 1
提问于2021-02-07
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Kafka Streams与Quarkus:实时处理事件
KSQL:Apache Kafka的开源Streaming SQL引擎
kafka sql入门
kafka实战演练,欲走大数据之路的台阶打造,通往的必经之路
Kafka 1.0.1案例详解之Kafka Streams
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券