Spring Boot将ObjectMapper注入Kafka JsonDeserializer
我想将Jackson的ObjectMapper注入到Kafka的ConsumerFactory的JsonDeserializer中。我已经做了这篇文章中提到的：
将ObjectMapper注入Spring Kafka序列化/反序列化程序
如何修复此问题并正确配置Kafka？
共有1个答案
对于每个侦听器，您需要一个不同的消费者/容器工厂。然后使用@kafkalistener上的containerFactory属性指定要使用的工厂。
-
我有一个使用Spring Batch编写的批处理作业 我在下面有一个配置文件： 我有Json线聚合如下： 我想注入对象映射器，不想在JsonLineAggregator类中创建它。我知道如何使用DI实现它吗？
-
我使用的是Spring Kafka 1.1.2-Spring Boot 1.5.0 RC版本，并且配置了一个自定义值serialiser/Deserialiser类，扩展/。这些类确实使用Jackson ObjectMapper，它可以通过构造函数提供。 是否可以从Spring上下文中注入ObjectMapper？我已经配置了一个ObjectMapper，我希望在序列化/反序列化程序中重用它。
-
本文向大家介绍springboot注入servlet的方法，包括了springboot注入servlet的方法的使用技巧和注意事项，需要的朋友参考一下 问：有了springMVC，为什么还要用servlet？有了servlet3的注解，为什么还要使用ServletRegistrationBean注入的方式？ 使用场景：在有些场景下，比如我们要使用hystrix-dashboard，这时候就需要注入
-
我有一个控制器 服务接口 我想在我的控制器中使用@autowired来使用该服务，但当我运行应用程序时，我得到以下错误 org.springframework.beans.factory.beanCreationException：创建名为“demo application”的bean时出错：注入autowired依赖项失败；嵌套异常为org.SpringFramework.Beans.Facto
-
本文向大家介绍在springboot中使用注解将值注入参数的操作，包括了在springboot中使用注解将值注入参数的操作的使用技巧和注意事项，需要的朋友参考一下 后端的许多管理系统需要登陆者的信息，如shiro登陆后，会将登陆者的信息存储在shiro的session，在使用时需要多行代码获取用户信息。可以把获取在shiro中的登陆者信息封装在一个类中，使用时获取。本文主要讲述如何使用注解将值注入
-
我需要在Spring-boot应用程序中使用默认的ObjectMapper作为单个实例。我是否可以简单地在应用程序内部@autowire ObjectMapper（在Spring-boot应用程序中默认创建的实例）而不创建@bean（因为我不想更改ObjectMapper的任何功能） https://docs.spring.io/spring-boot/docs/current/reference