Kafka-узел предоставляет API администратора, который имеет метод describeGroups()
.
Например:
const client = new kafka.KafkaClient();
const admin = new kafka.Admin(client);
admin.describeGroups(['my-consumer-group'], (err, res) => {
console.log(JSON.stringify(res, null, 1));
});
Вы также можете использовать API администрирования Kafka-узла для списка групп .