腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何在
spring
中将
对象
序列化
为json ad hoc
、
、
我创建了一个
Spring
引导应用
程序
,它将消息发送到
Kafka
队列(使用
spring
集成
kafka
支持)。我想发送任意
的
json
序列化
对象
。有没有办法在我
的
spring
boot应用
程序
中获得/注入json-de-/
序列化
程序
?或者如何即席
反
/
序列化
一个
对象
? 应用
序列化<
浏览 1
提问于2018-01-29
得票数 0
1
回答
Spring
Kafka
-
覆盖
作为
对象
提供
的
ConsumerFactory
的
反
序列化
程序
类
、
、
、
如果在属性中以
对象
而不是
类
名
的
形式
提供
,是否可以
覆盖
ConsumerFactory
的
已配置反
序列化
器?也许在ContainerCustomizer里?
浏览 26
提问于2021-08-11
得票数 0
回答已采纳
1
回答
Kafka
-在Consumer中反
序列化
对象
、
、
我们正在考虑在我们
的
消息传递中使用
Kafka
,我们
的
应用
程序
是使用
Spring
开发
的
。因此,我们计划使用
spring
-
kafka
。 public void listener(SomeClass abx
浏览 0
提问于2018-06-29
得票数 5
回答已采纳
3
回答
springboot-
kafka
java 8时间
序列化
、
目前使用
spring
2.0.4和
spring
2.1.8 template。我想简化交换,将
对象
发送到
kafka
模板,并使用json
作为
格式。但是,一些需要反
序列化
的
消息包含java.time.LocalDateTime。所以我
的
安排是
spring
: serialization: write_dates_as_timestamps: false<e
浏览 1
提问于2018-08-29
得票数 10
回答已采纳
1
回答
@Value在自定义
Kafka
反
序列化
器上为null
、
、
、
在application.yml中将PersonDeserializer配置为value-deserializer,在deserialize方法中,topicA和topicB都为空。@Component private String topicA; @Value("${app.topicB}")
浏览 0
提问于2018-10-12
得票数 0
3
回答
类
不在受信任
的
包中,尽管出现在受信任包
的
列表中。
、
我试图在两个不同
的
Spring
应用
程序
之间实现一个简单
的
Kafka
通信,没有任何特殊设置,这个应用
程序
只有一个kafkalistener。我为消费者
提供
的
服务如下:
kafka
: topic: consumer' 原因: ja
浏览 0
提问于2018-05-27
得票数 12
回答已采纳
3
回答
Spring
Boot
Kafka
关于
序列化
/反
序列化
的
新手问题
、
、
、
我刚接触
Kafka
(使用
Spring
Boot 2.2.4),我看到了一些示例,其中KafkaTemplate是字符串,字符串只是发送字符串。我正在考虑发送Json
对象
,我看到有两种不同
的
方法……一些人使用String,Object,还有一些人使用String,TheActualModelClass。 这两者之间有没有利弊?我假设主要
的
区别是类型化
的
模板只适用于一个模型,而
对象
可以向任何主题发送任何类型?除此之外还有什么?
浏览 0
提问于2020-02-01
得票数 1
2
回答
春季卡夫卡消费者消费消息
作为
LinkedHashMap,因此自动转换为双BigDecimal
、
、
、
、
我使用基于注释
的
spring
侦听器来使用
kafka
消息,代码如下所示Class Employee{private String address,所有字段都被正确映射并以正确
的
BigDecimal格式出现,但在另一个服务中使用BigDecimal
对象
时,帐户
对象
以LinkedHashMap和BigDecimal字段
的
形式出现。根据我
的
理解,主要原因可以是:将帐户声明为
对
浏览 5
提问于2020-11-04
得票数 0
回答已采纳
1
回答
Spring
引导
Kafka
类
反
序列化
-而不是在受信任
的
包中
、
、
、
我知道这个问题很常见,但是在遵循不同
的
解决方案之后,我找不到一个有效
的
解决方案。在收到
Kafka
中
的
消息时,我想反
序列化
字符串和自定义
的
类
对象
。用字符串很好,但对我
的
班不行。文件中有这样
的
内容:
kafka
: consumer: group-id: foo
spri
浏览 1
提问于2019-04-02
得票数 8
回答已采纳
1
回答
Kafka
:不同主题
的
不同反
序列化
器
、
、
、
目前,我正在使用
Spring
和@KafkaListener注释从不同
的
Kafka
主题中获取信息。是否可以在这个新主题中使用JsonDeserializer,对遗留主题使用KafkaAvroDeserializer?
浏览 5
提问于2022-10-18
得票数 1
回答已采纳
11
回答
Spring
Kafka
这个
类
不在受信任
的
包中
、
、
、
在库更新之前
的
Spring
/
Kafka
应用
程序
中,我使用以下
类
org.telegram.telegrambots.api.objects.Update将消息发送到
Kafka
主题。如你所见-他们有不同
的
包裹。应用
程序
重新启动后,我遇到以下问题: [org.springframework.
kafka
.KafkaListenerEndpointContainer#1-0-C-1] o.s.
kafka
.list
浏览 2
提问于2018-08-04
得票数 36
回答已采纳
1
回答
Spring
多串行化和消费者/容器工厂
、
、
、
在我
的
Spring
应用
程序
中,我用以下发件人/接收器配置了
Kafka
:public class KafkaSenderConfig { } public class KafkaReceiverConfig {
浏览 0
提问于2017-11-23
得票数 0
回答已采纳
1
回答
Spring
配置DefaultErrorHandler?
、
、
、
env变量,
Spring
自动获得了以下配置env变量,从而成功地使使用者运行:export
SPRING
_
KAFKA
_CONSUMER_GROUP-ID但是现在我想要自定义默认
的
错误处理
程序
,以使用指数退避。在ref文档中,我尝试向ApplicationConsumer
类
添加以下内容:public ConcurrentKafkaListenerConta
浏览 17
提问于2022-01-27
得票数 2
回答已采纳
1
回答
如何从与不同经纪人相关
的
多个
Kafka
主题中消费?
、
、
、
、
如何从与不同经纪人相关
的
多个
Kafka
主题中消费? 我有一个
Spring
应用
程序
,需要使用两个主题,但是主题与不同
的
Brokers相关联。我在@Listener注释中使用
Spring
,我看到了从两个主题中使用
的
方法,这些主题与同一个代理相关,而不是不同
的
代理。不幸
的
是,我在
Spring
或
Spring
文档中没有看到任何关于如何做到这一点
的
帮助。
浏览 4
提问于2021-02-19
得票数 1
回答已采纳
1
回答
如何构建一个使用KafkaJS生产者产生
的
消息
的
spring
消费者
、
中使用KafkaListener
作为
消费者。@org.springframework.
kafka
.annotation.KafkaListener(Update1:我应该定义这样
的
浏览 1
提问于2022-06-01
得票数 0
1
回答
Spring
用于多模型
类
的
消费工厂
、
、
、
我最近开始学习
Kafka
,我正试图在两个springboot微服务之间进行基本
的
交流。 return factory;这是正常工作
的
,我能够反
序列化
使用者服务中
的
用户
对象
。现在假设我还有20个这样
的
模型
类</e
浏览 4
提问于2022-09-29
得票数 0
1
回答
找不到
的
'org.springframework.
kafka
.core.
ConsumerFactory
‘
、
、
、
我需要使用带有org.springframework.
kafka
依赖关系
的
Apache使用
Spring
应用
程序
中
的
json
对象
消息,但我得到了以下错误: ************************required a bean of type 'org.springframework.
kafka
.core.
ConsumerFactory
' that could not be found.这是我
的
bean<em
浏览 2
提问于2020-03-22
得票数 3
回答已采纳
3
回答
类
不是org.apache.
kafka
.common.serialization.Deserializer
的
实例
、
、
、
、
我想实现
Kafka
生成器,它发送和接收Java
序列化
对象
。<String, SaleResponseFactory>
consumerFactory
() {import org.apache.
kafka
.common.serialization.Serializer; @Setter @NoArgsConstructor
浏览 3
提问于2020-11-08
得票数 2
回答已采纳
2
回答
如何使用
spring
引导设置
kafka
使用者并发
、
、
、
、
我正在编写一个基于Java
的
Kafka
消费者应用
程序
。我正在使用
Kafka
-客户端,
Spring
和
Spring
作为
我
的
应用
程序
.虽然
Spring
允许我轻松地编写
Kafka
消费者(而不是真正地编写ConcurrentKafkaListenerContainerFactory、
ConsumerFactory
等),但我希望能够为这些消费者定义/自定义一些属性。一个显而易见<e
浏览 1
提问于2018-05-10
得票数 4
回答已采纳
1
回答
如何在
Spring
和
Spring
中使用GenericMessageJacksonDeserializer?
、
@Bean final Map<String, Object> consumerProperties, GenericMessage>
consumerFactory
= new DefaultKafkaConsumerFactory<>(consumerProperties);
consum
浏览 5
提问于2017-09-30
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
“Spring和Kafka”Kafka整合Spring 深入挖掘-第1部分
Kafka消息队列学习进阶(四)-优化(配置/代码/集群
Spring Cloud Stream简单入门
精通springcloud:消息驱动的微服务,了解Spring Cloud Stream
02-02使用NoSQL数据库
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券