Ошибка весеннего потока данных в облаке при публикации в 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>

0 ответов

Другие вопросы по тегам