(*)kafka接收消息,去掉groupId

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----------接收到消息');