У меня есть монолитное приложение с jhipster и использующее kafka.Я следовал этому учебнику
Но у меня возникла такая проблема:
Resolved [org.springframework.messaging.MessageHandlingException: error occurred in message handler [org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$ProducerConfigurationMessageHandler@60776a72]; nested exception is org.apache.kafka.common.errors.SerializationException: Can't convert value of class [B to class org.apache.kafka.common.serialization.StringSerializer specified in value.serializer, failedMessage=GenericMessage [payload=byte[43], headers={contentType=application/json, id=36f92cbf-b185-9e69-1d23-a1e3b0420e5a, timestamp=1560846532039}]]
Я уже видел различные проблемы, такие как this one, и кажется, что проблемадолжно быть исправлено.Я посмотрел все в сети.Ниже приведена зависимость, которую я добавил в pom.xml
.
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream-binder-kafka</artifactId>
</dependency>
При подключении к этому URL-адресу http://localhost:8080/api/greetings/5
я должен увидеть сообщение.Вместо этого у меня есть внутренняя ошибка сервера [500] с этим сообщением:
"error occurred in message handler [org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder$ProducerConfigurationMessageHandler@60776a72]; nested exception is org.apache.kafka.common.errors.SerializationException: Can't convert value of class [B to class org.apache.kafka.common.serialization.StringSerializer specified in value.serializer