Специальные символы в сообщении потребляют Spring-интеграции-AWS

Мы отправляем сообщение в поток kinesis из приложения интеграции с пружиной, но при использовании сообщения через @StreamListener из приложения связывания kinesis мы получаем специальные символы, такие как "f t foo". Пожалуйста, найдите ниже фрагмент кода и дайте мне знать, есть ли какие-то дополнительные вещи, которые мы должны рассмотреть?

Отправка сообщения в Kinesis

Message<String> message = MessageBuilder.withPayload("foo")
            .setHeader(AwsHeaders.STREAM, TEST_STREAM)
            .setHeader("content-type","text/plain;charset=UTF-8")
            .build();
    kinesisSendChannel.send(message);

Получение сообщения

Charset UTF8 = Charset.forName("UTF-8");
byte[] bytes = (byte[]) message.getPayload();
String reverted = new String(bytes, UTF8);

0 ответов

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