Как сделать паузу Nest. js Кафка потребителя - PullRequest
0 голосов
/ 26 марта 2020

Я использую Kafka. js в проекте Nest. js. Вот как я инициализирую KafkaClient:


@Module({
...
providers: [{
      provide: 'KAFKA_CLIENT',
      useFactory: async (configService: KafkaClientConfigService) => {

        const kafkaOptions = configService.getKafkaOptions();
        return ClientProxyFactory.create(kafkaOptions);
      },
      inject: [KafkaClientConfigService],
    },
  ]
...
})

Теперь я внедряю KafkaClient в мой контроллер и могу sh использовать сообщения с интервалами. Хотя есть способ сделать это с Kafka. js с использованием consumer.pause(), я не смог найти ссылки на такую ​​опцию в KafkaClient.

Есть ли возможность сделать это, приостановив или задушив потребителя?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...