腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(5119)
视频
沙龙
1
回答
在
使用
Kafka
和
Apache
光束
的
上下
文中
,
Coder
和
Kafka
反
序列化
程序
之间
的
区别
是什么
?
apache-kafka
、
apache-beam
我是新来
的
阿帕奇
光束
我正在尝试按照文档
使用
KafKaIO从
Kafka
中读取数据。
在
创建PCollection
的
过程中,withValueDeserializerAndCoder方法允许您设置编码器
和
反
序列化
程序
。我不明白为什么我们可能需要反
序列化
程序
和
编码器。
浏览 22
提问于2019-10-16
得票数 0
回答已采纳
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
回答
如何在卡夫卡流中创建一个以HashMap为价值
的
状态存储?
apache-kafka-streams
我需要创建一个以字符串键HashMap作为值
的
状态存储。我尝试了以下两种方法。thread "main" java.lang.IllegalArgumentException: Unknown class for built-in serializer 有人能告诉我什么是创建州立商店
的
正确方法吗
浏览 0
提问于2016-08-29
得票数 6
回答已采纳
1
回答
使用
Python反
序列化
Java org.
apache
.
kafka
.common.serialization
序列化
对象
java
、
python
、
serialization
、
apache-kafka
我有一个Java
Kafka
生产者,它
使用
org.
apache
.
kafka
.common.serialization.LongSerializer作为关键
的
序列化
程序
,并且我正在尝试
使用
Python
Kafka
消费者来消费主题中
的
消息。我认为既然LongSerializer是org.
apache
.
kafka
的
一部分,那么在其他语言
的
所有官方<em
浏览 2
提问于2019-06-17
得票数 3
1
回答
如何设置卡夫卡KeyValueStore
的
值
反
/
序列化
器?
java
、
spring
、
apache-kafka-streams
、
spring-cloud-stream
我正在将来自卡夫卡主题
的
消息存储
在
KeyValueStore中,以便以后查询它们。:spring.cloud.stream.
kafka
.streams.bindings.input: consumer: materializedAs: all-messageskey-deserializer: org.
apache
.
kafka
.common.serialization.StringDeserializer v
浏览 1
提问于2019-07-03
得票数 1
回答已采纳
1
回答
如何在spring中将对象
序列化
为json ad hoc
json
、
spring-boot
、
apache-kafka
我创建了一个Spring引导应用
程序
,它将消息发送到
Kafka
队列(
使用
spring集成
kafka
支持)。我想发送任意
的
json
序列化
对象。有没有办法
在
我
的
spring boot应用
程序
中获得/注入json-de-/
序列化
程序
?或者如何即席
反
/
序列化
一个对象? 应用
序列化
有哪些好
的
实践?
浏览 1
提问于2018-01-29
得票数 0
2
回答
在
Kafka
中实现反
序列化
器
和
Serde有什么
区别
?
java
、
apache-kafka
、
kafka-consumer-api
、
apache-kafka-streams
当我
使用
使用
反
序列化
器
的
使用
者类
使用
一个主题时,我会遇到一个错误。定制
的
Serde类有
序列化
程序
和
反
序列化
器。但是,我试图理解为什么
使用
自定义serde来反
序列化
,然后
使用
者API就会产生错误,因为它不是org.
apache
.
kafka
.common.serialization.Deserializer
浏览 0
提问于2019-05-24
得票数 4
回答已采纳
1
回答
在
Kafka
序列化
器/反
序列化
器中配置功能
是什么
?
java
、
serialization
、
apache-kafka
、
deserialization
我正在研究为
Kafka
实现自定义
序列化
器/反
序列化
器。要实现
Kafka
自定义
序列化
程序
/反
序列化
器,我们必须分别实现org.
apache
.
kafka
.common.serialization.Serializer
和
org.
apache
.
kafka
.common.serialization.Deserializer我不明白
的
是configure(
浏览 2
提问于2020-01-31
得票数 1
回答已采纳
1
回答
Kafka
Streams:我可以为我
的
处理器订阅不同分区数
的
多个主题吗
apache-kafka
、
apache-kafka-streams
我正在尝试创建一个具有多个处理器
的
Kafka
Stream Topology,这些处理器订阅了正则表达式模式
和
多个主题。org.
apache
.
kafka
.streams.errors.TopologyException它们
之间
的
区别
是:topic_b: 3
浏览 10
提问于2021-09-24
得票数 0
1
回答
如何从原始缓冲区对象
Kafka
java中获取字符串消息
java
、
node.js
、
apache-kafka
、
node-kafka
当卡夫卡
的
消费者消费了卡夫卡
的
信息时,看起来- {"type":"Buffer","data":[91,13 .....]当我
在
nodejs消费者中
使用
m.message.value.toString('utf8')时,它会打印实际消息。但我需要在java
Kafka
消费中消费。我试过用property.put("value.serializer.encoding", "utf8")<e
浏览 0
提问于2019-03-11
得票数 0
1
回答
Kafka
流不断进入错误状态,应用
程序
无法启动
apache-kafka
、
apache-kafka-streams
我已经
在
kafka
streams上工作了很长一段时间。我被困在一个问题中,无法解决它。我期待着来自这个平台
的
一些帮助。所以场景是这样
的
。有许多客户
和
许多为这些客户工作
的
员工。我想要流式传输该主题,并希望以同一客户下
的
所有员工分组
的
方式构建一个物质化商店。我
使用
开源
的
ListSerializer
和
ListDeserializer类来完成这项工作。 所以主题定义是这样
的
。它从存储中读
浏览 2
提问于2020-05-16
得票数 1
2
回答
Apache
Camel vs
Apache
Kafka
apache-kafka
、
apache-camel
、
jms
、
messaging
据我所知,
Apache
Kafka
是异步消息传递平台,而
Apache
Camel是实现企业集成模式
的
平台。 那么,
Apache
Camel
和
Apache
Kafka
的
实际
区别
是什么
呢?我们计划用
Apache
Camel实现系统,这相对容易,但我们
的
客户想要
Apache
Kafka
而不是rational。选择
Apache<
浏览 4
提问于2018-01-30
得票数 16
3
回答
Spring Boot
Kafka
关于
序列化
/反
序列化
的
新手问题
java
、
spring
、
spring-boot
、
apache-kafka
我刚接触
Kafka
(
使用
Spring Boot 2.2.4),我看到了一些示例,其中KafkaTemplate是字符串,字符串只是发送字符串。我正在考虑发送Json对象,我看到有两种不同
的
方法……一些人
使用
String,Object,还有一些人
使用
String,TheActualModelClass。 这两者
之间
有没有利弊?我假设主要
的
区别
是类型化
的
模板只适用于一个模型,而对象可以向任何主题发送任何类型?除此之外还有什么?
浏览 0
提问于2020-02-01
得票数 1
2
回答
为
Kafka
重试死信队列中
的
消息
的
最佳实践
是什么
?
apache-kafka
、
error-handling
我们正在
使用
Kafka
作为微服务
之间
的
消息传递系统。我们有一个
kafka
消费者
在
听一个特定
的
主题,然后将数据发布到另一个主题中,由
Kafka
连接器负责将其发布到一些数据存储中。我们
使用
Apache
作为
序列化
机制。 我们需要使DLQ为
Kafka
消费者
和
Kafka
连接器添加容错功能。对于上面的第3点
和
第4点,我们想再次尝试来自DLQ
浏览 7
提问于2021-01-16
得票数 9
回答已采纳
1
回答
春云流产生不必要
的
复杂卡夫卡拓扑,为什么?
kotlin
、
apache-kafka
、
spring-cloud
、
apache-kafka-streams
、
spring-cloud-stream
我有一个KStream应用
程序
,它包含大量
的
KStreams、joins
和
其他操作。我使logging.level.org.springframework.
kafka
.config=debug能够验证正在生成
的
拓扑,并发现了许多根本没有意义
的
节点。KSTREAM-PROCESSOR-0000000006 (stores: []) <-- KSTREAM-BRANCHCHILD-0000000005
在
本地<
浏览 2
提问于2019-04-30
得票数 1
回答已采纳
1
回答
KafkaStreams:
在
KStream-KTable中处理反
序列化
异常
apache-kafka-streams
假设我们正在KStream
和
KTable
之间
进行内部连接,如下所示: JsonSerde当我运行应用
程序
并向这两个主题发送消息时,join将按预期
的
方式工作。.主题(流主题)发送消息时,应用
程序
将
使用
sensorValues关闭查看堆栈跟踪,我发现由于SensorMetaData中
的
模式更改,它在执行联接时未能反
序列化
SensorMeta
浏览 2
提问于2020-06-06
得票数 0
回答已采纳
2
回答
Spring Cloud Stream &
Kafka
:
Kafka
生产者
序列化
错误
spring-boot
、
spring-cloud-stream
、
kafka-producer-api
我对Spring Cloud Stream
和
Kafka
都是新手。在有效负载中发送字符串时,我从
kafka
生产者收到以下错误。任何帮助或见解都是非常感谢
的
。我尝试
使用
bytearray
序列化
程序
/反
序列化
程序
以及与纯文本相反
的
json。错误消息: org.
apache
.
kafka
.common.errors.SerializationException:无法将类[B ]<e
浏览 0
提问于2019-10-26
得票数 1
1
回答
LongSerializer与Serdes.LongSerde的卡夫卡系列化差异
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
我们正在编写一个发布到
Kafka
的
新应用
程序
,我们需要将消息
的
键
序列化
为一个长值。
在
检查
Kafka
文档进行
序列化
时,似乎有两个长
的
序列化
类,如LongSerializer
和
Serdes.LongSerde。我们试图为两者
之间
的
差异寻找一个参考,但没有找到任何解释差异
的
链接。如果有人能让我们知道/分享一个解释它们
之间
<e
浏览 1
提问于2019-10-01
得票数 0
回答已采纳
1
回答
将XML消息从Zerocode发布到
Kafka
主题
xml
、
apache-spark
、
apache-kafka
、
streaming
、
avro
我正在尝试
使用
进行流媒体平台(
Kafka
/ spark )
的
集成测试当我试图将消息放在零代码
的
K
浏览 1
提问于2019-09-18
得票数 0
1
回答
将Ktable按键分组后无效(负)时间戳
apache-kafka
、
apache-kafka-streams
我正在
使用
KakfkaStreams (2.3.0)来
使用
流
和
Ktable (压缩主题)
之间
的
连接来丰富价值。可能是因为
在
没有嵌入时间戳
的
情况下,
使用
了预0.10生产者客户端将此记录写入
Kafka
,或者是因为输入主题是
在
将
Kafka
集群升级到0.10+之前创建
的
。
在
阅读初始压缩主题时,我甚至尝试提供一个自定义时间戳提取器,但没有做任何
区别
。堆栈跟
浏览 1
提问于2019-08-28
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
深入理解Kafka Connect:转换器和序列化
Kafka 3.0.0新功能get
为什么会有Apache Kafka
“Spring和Kafka”Kafka整合Spring 深入挖掘-第1部分
当Flink遇到Kafka-FlinkKafkaConsumer使用详解
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券