我想学习如何使用 kafka 和 nestjs 创建微服务。但我得到如下错误
[Nest] 61226 - 07/18/2021, 12:12:16 PM [NestFactory] Starting Nest application...
[Nest] 61226 - 07/18/2021, 12:12:16 PM [InstanceLoader] AppModule dependencies initialized +27ms
[Nest] 61226 - 07/18/2021, 12:12:16 PM [ServerKafka] INFO [Consumer] Starting {"timestamp":"2021-07-18T05:12:16.850Z","logger":"kafkajs","groupId":"group-account-server"}
[Nest] 61226 - 07/18/2021, 12:12:41 PM [ServerKafka] INFO [ConsumerGroup] Consumer has joined the group {"timestamp":"2021-07-18T05:12:41.984Z","logger":"kafkajs","groupId":"group-account-server","memberId":"nestjs-consumer-server-d90648a1-60cf-4c23-8237-94ab2ea106d5","leaderId":"nestjs-consumer-server-d90648a1-60cf-4c23-8237-94ab2ea106d5","isLeader":true,"memberAssignment":{},"groupProtocol":"RoundRobinAssigner","duration":25120}
(node:61226) UnhandledPromiseRejectionWarning: TypeError: this.flushLogs is not a function
at /Users/skinnyguy/Projects2020/microservices-lamexpress/kafka-services/node_modules/@nestjs/microservices/nest-microservice.js:88:26
at ServerKafka.listen (/Users/skinnyguy/Projects2020/microservices-lamexpress/kafka-services/node_modules/@nestjs/microservices/server/server-kafka.js:43:13)
at processTicksAndRejections (internal/process/task_queues.js:95:5)
(Use `node --trace-warnings ...` to show where the warning was created)
(node:61226) …