diff --git a/cfg_parse/SimpleProducer.cpp b/cfg_parse/SimpleProducer.cpp
index e2cac2b..3b13914 100644
--- a/cfg_parse/SimpleProducer.cpp
+++ b/cfg_parse/SimpleProducer.cpp
@@ -28,6 +28,10 @@
 //lnk20241209添加队列选择
 #include <cstring>
 
+//引入消费起点
+#include "../include/rocketmq/DefaultMQPushConsumer.h"
+#include "../include/rocketmq/ConsumeType.h"
+
 // 引入提供的消费者接口头文件
 #include "../include/rocketmq/CPushConsumer.h"
 #include "../include/rocketmq/CCommon.h"
diff --git a/json/save2json.cpp b/json/save2json.cpp
index 1ef9f85..4477d91 100644
--- a/json/save2json.cpp
+++ b/json/save2json.cpp
@@ -680,6 +680,8 @@ void KafkaSendThread::run()
 			my_rocketmq_send(log_send);
 		}
 
+		QThread::msleep(1);  // ���� CPU ��תlnk20250326
+
 		/*if (data_gotten) {
 			LD_info_t* LD_info = find_LD_info_only_from_mp_id(data.mp_id.toAscii().data());
 			ied_t* ied;
@@ -801,7 +803,7 @@ void KafkaSendThread::run()
 		}*/
 	} //while(1) {
 
-
+	
 	//�߳̽����ݻ�������
 	ShutdownAndDestroyProducer();//lnk20241211
 }
@@ -2116,7 +2118,7 @@ int myMessageCallbackrecall(CPushConsumer* consumer, CMessageExt* msg)
 void mqconsumerThread::run()
 {
 	// ���������߲���
-    std::string consumerName = std::string(subdir) + intToString(g_front_seg_index);        // ��������ID
+    std::string consumerName = subdir + intToString(g_front_seg_index) + "_start_" + QDateTime::currentDateTime().toString("yyyyMMddhhmmss").toStdString();        // ��������ID+����ʱ�䣬��������ʷ��Ϣ
     std::string nameServer = G_MQCONSUMER_IPPORT;            			// NameServer��ַ