Как исправить «org.springframework.messaging.MessageHandlingException: ошибка произошла в обработчике сообщений»? - PullRequest
0 голосов
/ 18 июня 2019

У меня есть монолитное приложение с 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
...