Специальные символы в сообщении потребляют 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);