我正在寻找通过使用装饰器@MessagePattern('topic')或类似的东西使用nestjs/微服务每批消费消息。我想一起获取多个记录，处理它们，然后，在所有批处理完成时发送最新记录的提交。我以前在Spring Kafka中使用批处理侦听器来做这件事。
我应该使用kafkajs还是有方法使用nestjs/microservices ?
我认为nestJs在底层使用kafkaJs，即使你正在处理eachMessage，它也会进行批处理。但是，如果您需要对批处理进行更直接的控制，则可以使用https://kafka.js.org/docs/consuming#a-name-each-batch-a-eachbatch.