apache-kafka - NestJs/microservices Kafka - 每批消费消息

Question

我正在寻找通过使用装饰器@MessagePattern('topic') 或等效的东西来使用nestjs/microservices 每批消费消息。我想一起获取多条记录，处理它们，然后在处理完所有批次后发送最新记录的提交。我在 Spring Kafka 中使用过批处理侦听器来执行此操作。

我应该使用 kafkajs 还是使用 nestjs/microservices 的方法？

Answer 1

我认为nestJs 在后台使用了kafkaJs，即使您正在处理eachMessage. 但是，如果您需要更直接地控制批次，您可以使用https://kafka.js.org/docs/sumption#a-name-each-batch-a-eachbatch。