CLI группы потребителей kafka не отображает группу потребителей node-kafka - PullRequest
Новая
       55

CLI группы потребителей kafka не отображает группу потребителей node-kafka

0 голосов
/ 10 ноября 2019

У меня есть группа потребителей kafka, работающая на node.js и работающая на node-kafka. Когда эта группа потребителей активна или неактивна, я ожидаю, что об этом сообщит CLI групп потребителей kafa.

CLI групп потребителей kafka показывает потребителей консоли, а не только потребителя узла.

Я вижу группу потребителей узла в Kafka Tool. Он не отображается в выходных данных CLI групп Kafa-потребителей

kafka-consumer-groups --bootstrap-server localhost:9092 --list kafka-consumer-groups --bootstrap-server localhost:9092 --group node-kafka-consumer --describe

CLI-групп потребителей Kafka должен отображать всех потребителей - консольных и программных (в моем случае node-потребитель кафки)

1 Ответ

1 голос
/ 11 ноября 2019

Вот решение, которое использует объект ConsumerGroup kafka-node для записи смещений в kafka вместо zookeeper 

const { ConsumerGroup } = kafka;


const consumerOptions = {
  kafkaHost: 'localhost:9092',
  groupId: 'kafka-node-consumer-group',
  protocol: ['roundrobin'],
  fromOffset: 'earliest'
};

const topics = ['zoo_animals'];

const consumerGroup = new ConsumerGroup(
  { id: 'node-app-1', ...consumerOptions },
  topics
);

consumerGroup.on('message', onMessage);
consumerGroup.on('error', onError);

function onMessage(message) {
  console.log('message', message);
}

function onError(error) {
  console.log('error', error);
}

process.once('SIGINT', function() {
  consumerGroup.close(true, err => {
    if (err) {
      console.log('error closing consumer', err);
    } else {
      console.log('closed consumer');
    }
  });
});```
...