diff --git a/spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/integration/RocketMQMessageHandler.java b/spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/integration/RocketMQMessageHandler.java
index 47268539..6efe7955 100644
--- a/spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/integration/RocketMQMessageHandler.java
+++ b/spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/integration/RocketMQMessageHandler.java
@@ -98,6 +98,9 @@ public class RocketMQMessageHandler extends AbstractMessageHandler implements Li
 			producer = new DefaultMQProducer(destination);
 		}
 
+		producer.setVipChannelEnabled(
+				producerProperties.getExtension().getVipChannelEnabled());
+
 		Optional.ofNullable(instrumentationManager).ifPresent(manager -> {
 			producerInstrumentation = manager.getProducerInstrumentation(destination);
 			manager.addHealthInstrumentation(producerInstrumentation);
diff --git a/spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/properties/RocketMQProducerProperties.java b/spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/properties/RocketMQProducerProperties.java
index 1a05ad50..b526d960 100644
--- a/spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/properties/RocketMQProducerProperties.java
+++ b/spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/properties/RocketMQProducerProperties.java
@@ -45,6 +45,8 @@ public class RocketMQProducerProperties {
 	 */
 	private String transactionCheckListener;
 
+	private Boolean vipChannelEnabled = true;
+
 	public Boolean getEnabled() {
 		return enabled;
 	}
@@ -84,4 +86,12 @@ public class RocketMQProducerProperties {
 	public void setTransactionCheckListener(String transactionCheckListener) {
 		this.transactionCheckListener = transactionCheckListener;
 	}
+
+	public Boolean getVipChannelEnabled() {
+		return vipChannelEnabled;
+	}
+
+	public void setVipChannelEnabled(Boolean vipChannelEnabled) {
+		this.vipChannelEnabled = vipChannelEnabled;
+	}
 }