Ошибка весеннего потока данных в облаке при публикации в kafka error
Я работаю над POC по весеннему потоку клодата с использованием связующего файла kafka. Ошибка при отправке полезной нагрузки в kafka. Это отлично работает в Rabbit MQ, поэтому интересно, какие изменения нужно сделать, чтобы он работал в Kafka. Согласно Spring Cloud, это изменение канала сообщений должно быть плавным, и для его работы не требуется никаких изменений кода.
ОШИБКА 14088 --- [ctor-http-nio-4] osksupport.LoggingProducerListener: исключение при отправке сообщения с ключом ='null' и полезной нагрузкой ='{91, 91, 123, 34, 117, 112, 100, 97, 116, 101, 85, 115, 101, 114, 73, 100, 101, 110, 116, 105, 102, ...'на тему poctopic:
КОД СНОВА ДЛЯ ОТПРАВКИ КАФКА
public void sendToChannel(List<String> list,String name) {
MessageBuilder builder=MessageBuilder.withPayload(list.toString());
builder=builder.setHeader("SOURCE",name);
this.source.output().send(builder.build());
logger.info("successfully send payload to channel ");
}
ПОМ ВХОД ДЛЯ ВЯЗКИ КАФКА
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-stream-kafka</artifactId>
<version>2.1.3.RELEASE</version>
</dependency>