我正在使用Spring Framework的KafkaListener接口来收听Kafka主题。代码正在工作，但我猜我正在接收ASCII字符串中的消息。我不太确定为什么会这样。
这是我的代码：
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.stereotype.Service;
@Service
public class Receiver {
private static final Logger LOG = LoggerFactory.getLogger(Receiver.class);
@KafkaListener(topics = "mongoDBTest", groupId = "test")
public void listen(@Payload String cMessage) {
LOG.info("received message=" + cMessage);
Application.print();
}
}
消费时，例如“测试”，我得到“收到的消息=116,101,115,116”作为输出。
嗨，看起来有人以错误的方式消费消息，而不仅仅是字符串。如果你能在那部分修复它——那太棒了。
否则，您需要将这些字节解码为普通字符串。请尝试
String[] split = cMessage.split(",");
byte[] bytes = new byte[split.length];
for (int i = 0; i < split.length; i++) {
bytes[i] = Byte.parseByte(split[i]);
}
LOG.info("received message=" + new String(bytes));
