Я использую 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.
Есть ли возможность сделать это, приостановив или задушив потребителя?