microservices - 如何在nestjs kafka消费者选项中设置自动重置偏移值

Question

为了在我的 nestjs 微服务中实现 kafka 消费者，我在我的项目 main.ts 文件中进行了以下更改。我可以添加一些消费者选项。但我无法添加自动重置偏移选项。

import { NestFactory } from '@nestjs/core';
import { AppModule } from './app.module';
import {MicroserviceOptions, Transport} from '@nestjs/microservices';

async function bootstrap() {
  const port = new ConfigService().get('port')
  const app = await NestFactory.createMicroservice(AppModule, {
    transport: Transport.KAFKA,
    options: {
      client: {
        brokers: ["kafka:9092"],
        heartbeatInterval:3000
      },
      consumer: {
          groupId: 'nestjs-group-server-server',
          sessionTimeout:10000,
          readUncommitted:true,
      },
      subscribe: {
          fromBeginning: true
      },
      run :{
          autoCommit: true
      }
    }
  });
await app.listen();
}
bootstrap()