From 172d610dc79f5b563d1286f0fa75fdf72744a10f Mon Sep 17 00:00:00 2001
From: zhouxiang <zhouxiang.zzx@alibaba-inc.com>
Date: Tue, 10 May 2022 19:22:33 +0800
Subject: [PATCH] [ISSUE #3949] Add enableTopicMessageTypeCheck

---
 .../org/apache/rocketmq/proxy/config/ProxyConfig.java  | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/config/ProxyConfig.java b/proxy/src/main/java/org/apache/rocketmq/proxy/config/ProxyConfig.java
index 1eb5ab7d66..ead79f5228 100644
--- a/proxy/src/main/java/org/apache/rocketmq/proxy/config/ProxyConfig.java
+++ b/proxy/src/main/java/org/apache/rocketmq/proxy/config/ProxyConfig.java
@@ -95,6 +95,8 @@ public class ProxyConfig {
 
     private boolean enableACL = false;
 
+    private boolean enableTopicMessageTypeCheck = true;
+
     public boolean isEnablePrintJstack() {
         return enablePrintJstack;
     }
@@ -502,4 +504,12 @@ public class ProxyConfig {
     public void setEnableACL(boolean enableACL) {
         this.enableACL = enableACL;
     }
+
+    public boolean isEnableTopicMessageTypeCheck() {
+        return enableTopicMessageTypeCheck;
+    }
+
+    public void setEnableTopicMessageTypeCheck(boolean enableTopicMessageTypeCheck) {
+        this.enableTopicMessageTypeCheck = enableTopicMessageTypeCheck;
+    }
 }