在单元测试中使用 ConfigService - NestJS

Question

我有一个 Kafka ProducerService，如下所示：

@Injectable()
export class ProducerService implements OnModuleInit, OnApplicationShutdown {
  private logger = new Logger(ProducerService.name);
  public readonly topic: string;
  private readonly url: string;
  private readonly clientId: string;
  private readonly scramUsername: string;
  private readonly scramPassword: string;
  private kafka: Kafka;
  private producer: Producer;

  constructor(private config: ConfigService) {
    this.url = this.config.get<string>('kafka.brokerUrl');
    this.topic = this.config.get<string>('kafka.topic');
    this.clientId = this.config.get<string>('kafka.clientId');
    if(this.config.get<boolean>('kafka.scram.enabled') == true) {
      this.scramUsername = this.config.get<string>('kafka.scram.username');
      this.scramPassword = this.config.get<string>('kafka.scram.password');
    } else {
      this.scramUsername = "";
      this.scramPassword = "";
    }
    this.kafka = new Kafka({
      brokers: [this.url],
      clientId: this.clientId,
    });
    this.producer = this.kafka.producer();
  }

我在 KafkaModule 中导入 ConfigModule，这允许我在 中注入 ConfigService ProducerService 构造函数。

如何充分测试这项服务？ 我正在我的 Producer.spec.ts 文件中尝试像这样基本的东西：

describe('ProducerService', () => {
  const config = new ConfigService()
  const client = new ProducerService(config)
  
  beforeEach(async () => {
    await client.onModuleInit();
  })

  it('Should connect', () => {
    expect(client).toBeDefined()
  })

但我始终无法将配置加载到测试对象中：

KafkaJSNonRetriableError: Failed to connect: broker at index 0 is invalid "undefined"

Wrt。配置，我使用的是 .yaml。

Answer 1

您使用的是节点 16 吗？我遇到了同样的问题，我使用 nvm 切换到 Node 14。它现在可以工作了。

不知道实际问题是什么，但这可能会有所帮助。