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;
// to instantiate a ByteArrayMessageConverter, because Spring never
// calls the optimized method convertPayload(Message).
@Bean
- JacksonJsonMessageConverter jacksonJsonMessageConverter(ObjectMapper objectMapper)
+ JacksonJsonMessageConverter jacksonJsonMessageConverter()
{
JacksonJsonMessageConverter converter = new JacksonJsonMessageConverter();
DefaultJacksonJavaTypeMapper typeMapper = new DefaultJacksonJavaTypeMapper();