diff --git a/inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/config/loader/ClassResourceQueryConsumeConfig.java b/inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/config/loader/ClassResourceQueryConsumeConfig.java index dd0f4b32ec..570c437efb 100644 --- a/inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/config/loader/ClassResourceQueryConsumeConfig.java +++ b/inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/config/loader/ClassResourceQueryConsumeConfig.java @@ -73,6 +73,7 @@ public ConsumeConfig queryCurrentConsumeConfig(String sortTaskId) { topic.setInLongCluster(cacheZoneCluster); topic.setTopic(topicInfo.getTopic()); topic.setTopicType(cacheZone.getZoneType()); + topic.setProperties(topicInfo.getTopicProperties()); topics.add(topic); } }