ojoxdan
02/03/2024, 12:23 AMasync consumer({
topic,
subscriptionName,
consumerName,
}: {
topic: string;
subscriptionName: string;
consumerName?: string;
}): Promise<Pulsar.Consumer> {
const consumerConfig: Pulsar.ConsumerConfig = {
topic: topic,
subscription: subscriptionName,
};
if (consumerName) {
consumerConfig["consumerName"] = consumerName;
}
return await this.client.subscribe(consumerConfig);
}
}
The above throws the following error
[Error: Failed to create consumer: ConsumerBusy]
@David K