Closed cramhead closed 2 years ago
@cramhead you should be able to do
return new KafkaPubSub({
port: undefined,
topic: configService.get('KAFKA_SUBSCRIPTION_TOPIC_NAME'),
host: configService.get('KAFKA_BROKERS'),
});
Thanks, @smilovanovic. Closing this ticket
Would you be willing to accept a PR for adding support for multiple brokers. I'm thinking a comma delimited list, as node-rdkafka normally uses