diff --git a/api/app/lib/service/kafka.js b/api/app/lib/service/kafka.js
index 2a92dc1..aea984f 100644
--- a/api/app/lib/service/kafka.js
+++ b/api/app/lib/service/kafka.js
@@ -12,7 +12,7 @@ module.exports = async function factory(app, opts) {
          console.log('111111 ready 666666666666')
       })
 
-      let consumer = new Kafka.ConsumerGroup(Object.assign({}, { groupId: 'yunwei-platform-api', fromOffset: 'latest' }, { kafkaHost: opts.kafka.rootURL }), ['anxinyun_alarm'])
+      let consumer = new Kafka.ConsumerGroup(Object.assign({}, { fromOffset: 'latest' }, { kafkaHost: opts.kafka.rootURL }), ['anxinyun_alarm'])
       consumer.on('message', async function (message) {
          let msg = JSON.parse(message.value)
          console.log('kafka consumer----------接收到消息');