NestJs/microservices Kafka - 每批消费消息
NestJs/microservices Kafka - Consume messages per batch
我正在寻找使用装饰器 @MessagePattern('topic') 或类似的东西来使用 nestjs/microservices 每批消费消息。
我想一起获取多条记录，处理它们，然后在处理完所有批次后发送最新记录的提交。
我在 Spring Kafka 中使用 before batch listeners 来做到这一点。
我应该使用 kafkajs 还是有 nestjs/microservices 的方法？
我认为 nestJs 在后台使用 kafkaJs，即使您正在使用 eachMessage 进行处理，它也会进行批处理。但是，如果您需要对批次进行更直接的控制，您可以使用 https://kafka.js.org/docs/consuming#a-name-each-batch-a-eachbatch.
我正在寻找使用装饰器 @MessagePattern('topic') 或类似的东西来使用 nestjs/microservices 每批消费消息。 我想一起获取多条记录，处理它们，然后在处理完所有批次后发送最新记录的提交。 我在 Spring Kafka 中使用 before batch listeners 来做到这一点。
我应该使用 kafkajs 还是有 nestjs/microservices 的方法？
我认为 nestJs 在后台使用 kafkaJs，即使您正在使用 eachMessage 进行处理，它也会进行批处理。但是，如果您需要对批次进行更直接的控制，您可以使用 https://kafka.js.org/docs/consuming#a-name-each-batch-a-eachbatch.