diff --git a/external-service-impl/mqtt/src/main/java/org/apache/iotdb/mqtt/PayloadFormatManager.java b/external-service-impl/mqtt/src/main/java/org/apache/iotdb/mqtt/PayloadFormatManager.java
index 7bb051a85269..228b890b47f9 100644
--- a/external-service-impl/mqtt/src/main/java/org/apache/iotdb/mqtt/PayloadFormatManager.java
+++ b/external-service-impl/mqtt/src/main/java/org/apache/iotdb/mqtt/PayloadFormatManager.java
@@ -79,7 +79,8 @@ private static void makeMqttPluginDir() throws IOException {
   }
 
   private static void buildMqttPluginMap() throws IOException {
-    ServiceLoader<PayloadFormatter> payloadFormatters = ServiceLoader.load(PayloadFormatter.class);
+    ServiceLoader<PayloadFormatter> payloadFormatters =
+        ServiceLoader.load(PayloadFormatter.class, PayloadFormatManager.class.getClassLoader());
     for (PayloadFormatter formatter : payloadFormatters) {
       if (formatter == null) {
         logger.error("PayloadFormatManager(), formatter is null.");