From 64ee2af415f0c035c90f978709e92e344071c5f9 Mon Sep 17 00:00:00 2001
From: wuqun <wu.qun@free-sun.com.cn>
Date: Thu, 3 Nov 2022 13:34:31 +0800
Subject: [PATCH] =?UTF-8?q?(*)=E5=9B=9E=E9=80=80=E6=B3=A8=E9=87=8A?=
 =?UTF-8?q?=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 api/app/lib/service/kafka.js | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/api/app/lib/service/kafka.js b/api/app/lib/service/kafka.js
index 5c4cb9a..46adfbc 100644
--- a/api/app/lib/service/kafka.js
+++ b/api/app/lib/service/kafka.js
@@ -12,12 +12,12 @@ module.exports = async function factory(app, opts) {
          console.log('111111 ready 666666666666')
       })
 
-      // const kafka = {
-      //    producer: producer,
-      //    configUpdateMessage: opts.configUpdateMessage || {}
-      // };
+      const kafka = {
+         producer: producer,
+         configUpdateMessage: opts.configUpdateMessage || {}
+      };
 
-      // app.fs.kafka = kafka;
+      app.fs.kafka = kafka;
       app.fs.logger.log('debug', "[FS-KAFKA]", "Init.Success");