Open hosh opened 1 year ago
pass existing kafkaClient through consumerGroup, consumerGroupStream, producerStream
Add the capability to reuse a kafkaClient() and avoid excessive metadata refreshes
pass existing kafkaClient through consumerGroup, consumerGroupStream, producerStream
Add the capability to reuse a kafkaClient() and avoid excessive metadata refreshes