当 onMessage 要转换的消息类型为 byte[] 时，报错：ClassCastException: java.lang.String cannot be cast to [B

[BrightX]

rocketmq-spring/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java

Lines 543 to 551 in b3963f7

	String str = new String(messageExt.getBody(), Charset.forName(charset));
	if (Objects.equals(messageType, String.class)) {
	return str;
	} else {
	// If msgType not string, use objectMapper change it.
	try {
	if (messageType instanceof Class) {
	//if the messageType has not Generic Parameter
	return this.getMessageConverter().fromMessage(MessageBuilder.withPayload(str).build(), (Class<?>) messageType);

我注意到这里当要转换的类型为 byte[] 时，会调用spring-messaging 的 ByteArrayMessageConverter 的 convertFromInternal，而这个方法会原样返回 payload。而截图的 L551 行，将 payload 设置成了 str，导致 String 到 byte[] 的类型转换异常 ClassCastException: java.lang.String cannot be cast to [B 。

org.springframework.messaging.converter.ByteArrayMessageConverter#convertFromInternal

    return message.getPayload();