import org.springframework.kafka.support.converter.JacksonJsonMessageConverter;
import org.springframework.kafka.support.mapping.DefaultJacksonJavaTypeMapper;
import org.springframework.kafka.support.mapping.JacksonJavaTypeMapper;
+import tools.jackson.databind.ObjectMapper;
import java.util.HashMap;
import java.util.Map;
public class ApplicationConfiguration
{
@Bean
- JacksonJsonMessageConverter jacksonJsonMessageConverter()
+ JacksonJsonMessageConverter jacksonJsonMessageConverter(ObjectMapper objectMapper)
{
JacksonJsonMessageConverter converter = new JacksonJsonMessageConverter();
DefaultJacksonJavaTypeMapper typeMapper = new DefaultJacksonJavaTypeMapper();