From fab33abbcb8cea9ad74a75affa1944818d0e0679 Mon Sep 17 00:00:00 2001
From: druidliu <druidliu@tencent.com>
Date: Sun, 9 Oct 2022 19:53:00 +0800
Subject: [PATCH] Fix the system topic schema not compatible bug. (#117)

---
 .../java/org/apache/pulsar/broker/service/AbstractTopic.java | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java
index 69c51c77d44a5..4f32e84aba2da 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java
@@ -154,6 +154,11 @@ public AbstractTopic(String topic, BrokerService brokerService) {
         this.preciseTopicPublishRateLimitingEnable =
                 brokerService.pulsar().getConfiguration().isPreciseTopicPublishRateLimiterEnable();
         updatePublishDispatcher(Optional.empty());
+
+        if (isSystemTopic()) {
+            schemaCompatibilityStrategy =
+                    brokerService.pulsar().getConfig().getSystemTopicSchemaCompatibilityStrategy();
+        }
     }
 
     protected boolean isProducersExceeded() {