Open abdulyasin opened 5 years ago
On the latest kafka version, the group state name "AwaitingSync" has been renamed by "CompletingRebalance" state. So self.cluster.getConsumer not listening for messages at all
is this issue resolved please let me know ...i need help on this
Consumer not listening for messages at all
I am trying to access consumer by cluster as shown below:
let consumer = self.cluster.getConsumer