diff --git a/PhaseCompAcq/PhaseCompAcq.pro b/PhaseCompAcq/PhaseCompAcq.pro
index c5e895b..ebb2309 100644
--- a/PhaseCompAcq/PhaseCompAcq.pro
+++ b/PhaseCompAcq/PhaseCompAcq.pro
@@ -22,8 +22,8 @@
 else: unix:!android: target.path = /opt/$${TARGET}/bin
 !isEmpty(target.path): INSTALLS += target
 
-#unix:!macx: LIBS += -L$$PWD/lib/librdkafka/ -lrdkafka -lrdkafka++
-#INCLUDEPATH += $$PWD/include/librdkafka
-#DEPENDPATH += $$PWD/include/librdkafka
+unix:!macx: LIBS += -L$$PWD/lib/librdkafka/ -lrdkafka -lrdkafka++
+INCLUDEPATH += $$PWD/include/librdkafka
+DEPENDPATH += $$PWD/include/librdkafka
 
 DISTFILES += conf/config.ini

diff --git a/PhaseCompAcq/PhaseCompAcq.pro b/PhaseCompAcq/PhaseCompAcq.pro
index c5e895b..ebb2309 100644
--- a/PhaseCompAcq/PhaseCompAcq.pro
+++ b/PhaseCompAcq/PhaseCompAcq.pro
@@ -22,8 +22,8 @@
 else: unix:!android: target.path = /opt/$${TARGET}/bin
 !isEmpty(target.path): INSTALLS += target
 
-#unix:!macx: LIBS += -L$$PWD/lib/librdkafka/ -lrdkafka -lrdkafka++
-#INCLUDEPATH += $$PWD/include/librdkafka
-#DEPENDPATH += $$PWD/include/librdkafka
+unix:!macx: LIBS += -L$$PWD/lib/librdkafka/ -lrdkafka -lrdkafka++
+INCLUDEPATH += $$PWD/include/librdkafka
+DEPENDPATH += $$PWD/include/librdkafka
 
 DISTFILES += conf/config.ini
diff --git a/PhaseCompAcq/PhaseDevice.cpp b/PhaseCompAcq/PhaseDevice.cpp
index afc2687..bffa877 100644
--- a/PhaseCompAcq/PhaseDevice.cpp
+++ b/PhaseCompAcq/PhaseDevice.cpp
@@ -7,9 +7,9 @@
     connect(&this->serialUtil, &QSerialPortUtil::dataRecieved,
             this, &PhaseDevice::dataReceivedHandler);
 
-//    kafkaUtil.setBrokers(SettingConfig::getInstance().KAFKA_BROKERS);
-//    kafkaUtil.setTopic(SettingConfig::getInstance().KAFKA_DATA_TOPIC);
-//    kafkaUtil.createProducer();
+    kafkaUtil.setBrokers(SettingConfig::getInstance().KAFKA_BROKERS);
+    kafkaUtil.setTopic(SettingConfig::getInstance().KAFKA_DATA_TOPIC);
+    kafkaUtil.createProducer();
 }
 
 PhaseDevice::~PhaseDevice()
@@ -128,7 +128,7 @@
                 QJsonObject jsonObj = phaseData->toJSON(i - 1);
                 jsonObj.insert("clientId", SettingConfig::getInstance().CLIENT_ID);
                 jsonObj.insert("deviceId", devCode);
-//                kafkaUtil.produceMessage(QString(QJsonDocument(jsonObj).toJson(QJsonDocument::Compact)));
+                kafkaUtil.produceMessage(QString(QJsonDocument(jsonObj).toJson(QJsonDocument::Compact)));
             }
         }
     }

diff --git a/PhaseCompAcq/PhaseCompAcq.pro b/PhaseCompAcq/PhaseCompAcq.pro
index c5e895b..ebb2309 100644
--- a/PhaseCompAcq/PhaseCompAcq.pro
+++ b/PhaseCompAcq/PhaseCompAcq.pro
@@ -22,8 +22,8 @@
 else: unix:!android: target.path = /opt/$${TARGET}/bin
 !isEmpty(target.path): INSTALLS += target
 
-#unix:!macx: LIBS += -L$$PWD/lib/librdkafka/ -lrdkafka -lrdkafka++
-#INCLUDEPATH += $$PWD/include/librdkafka
-#DEPENDPATH += $$PWD/include/librdkafka
+unix:!macx: LIBS += -L$$PWD/lib/librdkafka/ -lrdkafka -lrdkafka++
+INCLUDEPATH += $$PWD/include/librdkafka
+DEPENDPATH += $$PWD/include/librdkafka
 
 DISTFILES += conf/config.ini
diff --git a/PhaseCompAcq/PhaseDevice.cpp b/PhaseCompAcq/PhaseDevice.cpp
index afc2687..bffa877 100644
--- a/PhaseCompAcq/PhaseDevice.cpp
+++ b/PhaseCompAcq/PhaseDevice.cpp
@@ -7,9 +7,9 @@
     connect(&this->serialUtil, &QSerialPortUtil::dataRecieved,
             this, &PhaseDevice::dataReceivedHandler);
 
-//    kafkaUtil.setBrokers(SettingConfig::getInstance().KAFKA_BROKERS);
-//    kafkaUtil.setTopic(SettingConfig::getInstance().KAFKA_DATA_TOPIC);
-//    kafkaUtil.createProducer();
+    kafkaUtil.setBrokers(SettingConfig::getInstance().KAFKA_BROKERS);
+    kafkaUtil.setTopic(SettingConfig::getInstance().KAFKA_DATA_TOPIC);
+    kafkaUtil.createProducer();
 }
 
 PhaseDevice::~PhaseDevice()
@@ -128,7 +128,7 @@
                 QJsonObject jsonObj = phaseData->toJSON(i - 1);
                 jsonObj.insert("clientId", SettingConfig::getInstance().CLIENT_ID);
                 jsonObj.insert("deviceId", devCode);
-//                kafkaUtil.produceMessage(QString(QJsonDocument(jsonObj).toJson(QJsonDocument::Compact)));
+                kafkaUtil.produceMessage(QString(QJsonDocument(jsonObj).toJson(QJsonDocument::Compact)));
             }
         }
     }
diff --git a/PhaseCompAcq/PhaseDevice.h b/PhaseCompAcq/PhaseDevice.h
index aa7d822..887ed10 100644
--- a/PhaseCompAcq/PhaseDevice.h
+++ b/PhaseCompAcq/PhaseDevice.h
@@ -5,7 +5,7 @@
 #include "common/utils/QSerialPortUtil.h"
 #include "common/utils/QLogUtil.h"
 #include "common/utils/SettingConfig.h"
-//#include "common/utils/QKafkaUtil.h"
+#include "common/utils/QKafkaUtil.h"
 #include "protocol/PhaseProtocolBM.h"
 
 class PhaseDevice : public QObject
@@ -35,7 +35,7 @@
     int baudRate;
 
     QSerialPortUtil serialUtil;
-//    QKafkaUtil kafkaUtil;
+    QKafkaUtil kafkaUtil;
     QByteArray dataBuff;
 
 signals:

diff --git a/PhaseCompAcq/PhaseCompAcq.pro b/PhaseCompAcq/PhaseCompAcq.pro
index c5e895b..ebb2309 100644
--- a/PhaseCompAcq/PhaseCompAcq.pro
+++ b/PhaseCompAcq/PhaseCompAcq.pro
@@ -22,8 +22,8 @@
 else: unix:!android: target.path = /opt/$${TARGET}/bin
 !isEmpty(target.path): INSTALLS += target
 
-#unix:!macx: LIBS += -L$$PWD/lib/librdkafka/ -lrdkafka -lrdkafka++
-#INCLUDEPATH += $$PWD/include/librdkafka
-#DEPENDPATH += $$PWD/include/librdkafka
+unix:!macx: LIBS += -L$$PWD/lib/librdkafka/ -lrdkafka -lrdkafka++
+INCLUDEPATH += $$PWD/include/librdkafka
+DEPENDPATH += $$PWD/include/librdkafka
 
 DISTFILES += conf/config.ini
diff --git a/PhaseCompAcq/PhaseDevice.cpp b/PhaseCompAcq/PhaseDevice.cpp
index afc2687..bffa877 100644
--- a/PhaseCompAcq/PhaseDevice.cpp
+++ b/PhaseCompAcq/PhaseDevice.cpp
@@ -7,9 +7,9 @@
     connect(&this->serialUtil, &QSerialPortUtil::dataRecieved,
             this, &PhaseDevice::dataReceivedHandler);
 
-//    kafkaUtil.setBrokers(SettingConfig::getInstance().KAFKA_BROKERS);
-//    kafkaUtil.setTopic(SettingConfig::getInstance().KAFKA_DATA_TOPIC);
-//    kafkaUtil.createProducer();
+    kafkaUtil.setBrokers(SettingConfig::getInstance().KAFKA_BROKERS);
+    kafkaUtil.setTopic(SettingConfig::getInstance().KAFKA_DATA_TOPIC);
+    kafkaUtil.createProducer();
 }
 
 PhaseDevice::~PhaseDevice()
@@ -128,7 +128,7 @@
                 QJsonObject jsonObj = phaseData->toJSON(i - 1);
                 jsonObj.insert("clientId", SettingConfig::getInstance().CLIENT_ID);
                 jsonObj.insert("deviceId", devCode);
-//                kafkaUtil.produceMessage(QString(QJsonDocument(jsonObj).toJson(QJsonDocument::Compact)));
+                kafkaUtil.produceMessage(QString(QJsonDocument(jsonObj).toJson(QJsonDocument::Compact)));
             }
         }
     }
diff --git a/PhaseCompAcq/PhaseDevice.h b/PhaseCompAcq/PhaseDevice.h
index aa7d822..887ed10 100644
--- a/PhaseCompAcq/PhaseDevice.h
+++ b/PhaseCompAcq/PhaseDevice.h
@@ -5,7 +5,7 @@
 #include "common/utils/QSerialPortUtil.h"
 #include "common/utils/QLogUtil.h"
 #include "common/utils/SettingConfig.h"
-//#include "common/utils/QKafkaUtil.h"
+#include "common/utils/QKafkaUtil.h"
 #include "protocol/PhaseProtocolBM.h"
 
 class PhaseDevice : public QObject
@@ -35,7 +35,7 @@
     int baudRate;
 
     QSerialPortUtil serialUtil;
-//    QKafkaUtil kafkaUtil;
+    QKafkaUtil kafkaUtil;
     QByteArray dataBuff;
 
 signals:
diff --git a/PhaseCompAcq/common/common.pri b/PhaseCompAcq/common/common.pri
index 84f57ae..6280f64 100644
--- a/PhaseCompAcq/common/common.pri
+++ b/PhaseCompAcq/common/common.pri
@@ -3,7 +3,7 @@
 SOURCES += $$PWD/utils/QByteUtil.cpp
 SOURCES += $$PWD/utils/QSerialPortUtil.cpp
 SOURCES += $$PWD/utils/QLogUtil.cpp
-#SOURCES += $$PWD/utils/QKafkaUtil.cpp
+SOURCES += $$PWD/utils/QKafkaUtil.cpp
 SOURCES += $$PWD/utils/HttpRequestUtil.cpp
 SOURCES += $$PWD/utils/MD5.cpp
 SOURCES += $$PWD/HttpRequestController.cpp
@@ -12,7 +12,7 @@
 HEADERS += $$PWD/utils/QByteUtil.h
 HEADERS += $$PWD/utils/QSerialPortUtil.h
 HEADERS += $$PWD/utils/QLogUtil.h
-#HEADERS += $$PWD/utils/QKafkaUtil.h
+HEADERS += $$PWD/utils/QKafkaUtil.h
 HEADERS += $$PWD/utils/HttpRequestUtil.h
 HEADERS += $$PWD/utils/DefHead.h
 HEADERS += $$PWD/utils/MD5.h

diff --git a/PhaseCompAcq/PhaseCompAcq.pro b/PhaseCompAcq/PhaseCompAcq.pro
index c5e895b..ebb2309 100644
--- a/PhaseCompAcq/PhaseCompAcq.pro
+++ b/PhaseCompAcq/PhaseCompAcq.pro
@@ -22,8 +22,8 @@
 else: unix:!android: target.path = /opt/$${TARGET}/bin
 !isEmpty(target.path): INSTALLS += target
 
-#unix:!macx: LIBS += -L$$PWD/lib/librdkafka/ -lrdkafka -lrdkafka++
-#INCLUDEPATH += $$PWD/include/librdkafka
-#DEPENDPATH += $$PWD/include/librdkafka
+unix:!macx: LIBS += -L$$PWD/lib/librdkafka/ -lrdkafka -lrdkafka++
+INCLUDEPATH += $$PWD/include/librdkafka
+DEPENDPATH += $$PWD/include/librdkafka
 
 DISTFILES += conf/config.ini
diff --git a/PhaseCompAcq/PhaseDevice.cpp b/PhaseCompAcq/PhaseDevice.cpp
index afc2687..bffa877 100644
--- a/PhaseCompAcq/PhaseDevice.cpp
+++ b/PhaseCompAcq/PhaseDevice.cpp
@@ -7,9 +7,9 @@
     connect(&this->serialUtil, &QSerialPortUtil::dataRecieved,
             this, &PhaseDevice::dataReceivedHandler);
 
-//    kafkaUtil.setBrokers(SettingConfig::getInstance().KAFKA_BROKERS);
-//    kafkaUtil.setTopic(SettingConfig::getInstance().KAFKA_DATA_TOPIC);
-//    kafkaUtil.createProducer();
+    kafkaUtil.setBrokers(SettingConfig::getInstance().KAFKA_BROKERS);
+    kafkaUtil.setTopic(SettingConfig::getInstance().KAFKA_DATA_TOPIC);
+    kafkaUtil.createProducer();
 }
 
 PhaseDevice::~PhaseDevice()
@@ -128,7 +128,7 @@
                 QJsonObject jsonObj = phaseData->toJSON(i - 1);
                 jsonObj.insert("clientId", SettingConfig::getInstance().CLIENT_ID);
                 jsonObj.insert("deviceId", devCode);
-//                kafkaUtil.produceMessage(QString(QJsonDocument(jsonObj).toJson(QJsonDocument::Compact)));
+                kafkaUtil.produceMessage(QString(QJsonDocument(jsonObj).toJson(QJsonDocument::Compact)));
             }
         }
     }
diff --git a/PhaseCompAcq/PhaseDevice.h b/PhaseCompAcq/PhaseDevice.h
index aa7d822..887ed10 100644
--- a/PhaseCompAcq/PhaseDevice.h
+++ b/PhaseCompAcq/PhaseDevice.h
@@ -5,7 +5,7 @@
 #include "common/utils/QSerialPortUtil.h"
 #include "common/utils/QLogUtil.h"
 #include "common/utils/SettingConfig.h"
-//#include "common/utils/QKafkaUtil.h"
+#include "common/utils/QKafkaUtil.h"
 #include "protocol/PhaseProtocolBM.h"
 
 class PhaseDevice : public QObject
@@ -35,7 +35,7 @@
     int baudRate;
 
     QSerialPortUtil serialUtil;
-//    QKafkaUtil kafkaUtil;
+    QKafkaUtil kafkaUtil;
     QByteArray dataBuff;
 
 signals:
diff --git a/PhaseCompAcq/common/common.pri b/PhaseCompAcq/common/common.pri
index 84f57ae..6280f64 100644
--- a/PhaseCompAcq/common/common.pri
+++ b/PhaseCompAcq/common/common.pri
@@ -3,7 +3,7 @@
 SOURCES += $$PWD/utils/QByteUtil.cpp
 SOURCES += $$PWD/utils/QSerialPortUtil.cpp
 SOURCES += $$PWD/utils/QLogUtil.cpp
-#SOURCES += $$PWD/utils/QKafkaUtil.cpp
+SOURCES += $$PWD/utils/QKafkaUtil.cpp
 SOURCES += $$PWD/utils/HttpRequestUtil.cpp
 SOURCES += $$PWD/utils/MD5.cpp
 SOURCES += $$PWD/HttpRequestController.cpp
@@ -12,7 +12,7 @@
 HEADERS += $$PWD/utils/QByteUtil.h
 HEADERS += $$PWD/utils/QSerialPortUtil.h
 HEADERS += $$PWD/utils/QLogUtil.h
-#HEADERS += $$PWD/utils/QKafkaUtil.h
+HEADERS += $$PWD/utils/QKafkaUtil.h
 HEADERS += $$PWD/utils/HttpRequestUtil.h
 HEADERS += $$PWD/utils/DefHead.h
 HEADERS += $$PWD/utils/MD5.h
diff --git a/PhaseCompAcq/conf/config.ini b/PhaseCompAcq/conf/config.ini
index 7d0fdb1..016416e 100644
--- a/PhaseCompAcq/conf/config.ini
+++ b/PhaseCompAcq/conf/config.ini
@@ -2,7 +2,7 @@
 baudRate=115200
 
 [kafka]
-needKafka=0
+needKafka=1
 brokers="111.198.10.15:12502"
 dataTopic="cppTest"
 
@@ -14,4 +14,4 @@
 baseUrl="http://111.198.10.15:11410"
 
 [log]
-basePath="D:/Workspace Qt/ZXSSCJ-Release/Phase/logs/"
+basePath="/home/admin/Qt/ZXSSCJ-Release/PhaseCompAcq/logs/"

diff --git a/PhaseCompAcq/PhaseCompAcq.pro b/PhaseCompAcq/PhaseCompAcq.pro
index c5e895b..ebb2309 100644
--- a/PhaseCompAcq/PhaseCompAcq.pro
+++ b/PhaseCompAcq/PhaseCompAcq.pro
@@ -22,8 +22,8 @@
 else: unix:!android: target.path = /opt/$${TARGET}/bin
 !isEmpty(target.path): INSTALLS += target
 
-#unix:!macx: LIBS += -L$$PWD/lib/librdkafka/ -lrdkafka -lrdkafka++
-#INCLUDEPATH += $$PWD/include/librdkafka
-#DEPENDPATH += $$PWD/include/librdkafka
+unix:!macx: LIBS += -L$$PWD/lib/librdkafka/ -lrdkafka -lrdkafka++
+INCLUDEPATH += $$PWD/include/librdkafka
+DEPENDPATH += $$PWD/include/librdkafka
 
 DISTFILES += conf/config.ini
diff --git a/PhaseCompAcq/PhaseDevice.cpp b/PhaseCompAcq/PhaseDevice.cpp
index afc2687..bffa877 100644
--- a/PhaseCompAcq/PhaseDevice.cpp
+++ b/PhaseCompAcq/PhaseDevice.cpp
@@ -7,9 +7,9 @@
     connect(&this->serialUtil, &QSerialPortUtil::dataRecieved,
             this, &PhaseDevice::dataReceivedHandler);
 
-//    kafkaUtil.setBrokers(SettingConfig::getInstance().KAFKA_BROKERS);
-//    kafkaUtil.setTopic(SettingConfig::getInstance().KAFKA_DATA_TOPIC);
-//    kafkaUtil.createProducer();
+    kafkaUtil.setBrokers(SettingConfig::getInstance().KAFKA_BROKERS);
+    kafkaUtil.setTopic(SettingConfig::getInstance().KAFKA_DATA_TOPIC);
+    kafkaUtil.createProducer();
 }
 
 PhaseDevice::~PhaseDevice()
@@ -128,7 +128,7 @@
                 QJsonObject jsonObj = phaseData->toJSON(i - 1);
                 jsonObj.insert("clientId", SettingConfig::getInstance().CLIENT_ID);
                 jsonObj.insert("deviceId", devCode);
-//                kafkaUtil.produceMessage(QString(QJsonDocument(jsonObj).toJson(QJsonDocument::Compact)));
+                kafkaUtil.produceMessage(QString(QJsonDocument(jsonObj).toJson(QJsonDocument::Compact)));
             }
         }
     }
diff --git a/PhaseCompAcq/PhaseDevice.h b/PhaseCompAcq/PhaseDevice.h
index aa7d822..887ed10 100644
--- a/PhaseCompAcq/PhaseDevice.h
+++ b/PhaseCompAcq/PhaseDevice.h
@@ -5,7 +5,7 @@
 #include "common/utils/QSerialPortUtil.h"
 #include "common/utils/QLogUtil.h"
 #include "common/utils/SettingConfig.h"
-//#include "common/utils/QKafkaUtil.h"
+#include "common/utils/QKafkaUtil.h"
 #include "protocol/PhaseProtocolBM.h"
 
 class PhaseDevice : public QObject
@@ -35,7 +35,7 @@
     int baudRate;
 
     QSerialPortUtil serialUtil;
-//    QKafkaUtil kafkaUtil;
+    QKafkaUtil kafkaUtil;
     QByteArray dataBuff;
 
 signals:
diff --git a/PhaseCompAcq/common/common.pri b/PhaseCompAcq/common/common.pri
index 84f57ae..6280f64 100644
--- a/PhaseCompAcq/common/common.pri
+++ b/PhaseCompAcq/common/common.pri
@@ -3,7 +3,7 @@
 SOURCES += $$PWD/utils/QByteUtil.cpp
 SOURCES += $$PWD/utils/QSerialPortUtil.cpp
 SOURCES += $$PWD/utils/QLogUtil.cpp
-#SOURCES += $$PWD/utils/QKafkaUtil.cpp
+SOURCES += $$PWD/utils/QKafkaUtil.cpp
 SOURCES += $$PWD/utils/HttpRequestUtil.cpp
 SOURCES += $$PWD/utils/MD5.cpp
 SOURCES += $$PWD/HttpRequestController.cpp
@@ -12,7 +12,7 @@
 HEADERS += $$PWD/utils/QByteUtil.h
 HEADERS += $$PWD/utils/QSerialPortUtil.h
 HEADERS += $$PWD/utils/QLogUtil.h
-#HEADERS += $$PWD/utils/QKafkaUtil.h
+HEADERS += $$PWD/utils/QKafkaUtil.h
 HEADERS += $$PWD/utils/HttpRequestUtil.h
 HEADERS += $$PWD/utils/DefHead.h
 HEADERS += $$PWD/utils/MD5.h
diff --git a/PhaseCompAcq/conf/config.ini b/PhaseCompAcq/conf/config.ini
index 7d0fdb1..016416e 100644
--- a/PhaseCompAcq/conf/config.ini
+++ b/PhaseCompAcq/conf/config.ini
@@ -2,7 +2,7 @@
 baudRate=115200
 
 [kafka]
-needKafka=0
+needKafka=1
 brokers="111.198.10.15:12502"
 dataTopic="cppTest"
 
@@ -14,4 +14,4 @@
 baseUrl="http://111.198.10.15:11410"
 
 [log]
-basePath="D:/Workspace Qt/ZXSSCJ-Release/Phase/logs/"
+basePath="/home/admin/Qt/ZXSSCJ-Release/PhaseCompAcq/logs/"
diff --git a/ZXSSCJ.pro b/ZXSSCJ.pro
index 65aaacc..87b1bd3 100644
--- a/ZXSSCJ.pro
+++ b/ZXSSCJ.pro
@@ -3,7 +3,7 @@
 #定义了ordered表示子项目按照添加的顺序来编译
 #CONFIG  += ordered
 
-#SUBDIRS += CounterAcq       #计数器数据采集
+SUBDIRS += CounterAcq       #计数器数据采集
 SUBDIRS += PhaseCompAcq     #比相仪数据采集
 #SUBDIRS += DevStatusAcq
 #SUBDIRS += HClockAcq        #氢钟状态数据采集