kafka消费者组在kafka-node中获取重复消息

const kafka = require('kafka-node');
const ConsumerGroup = kafka.ConsumerGroup;

const consumerOptions = {
  kafkaHost: 'your_kafka_host:9092',
  groupId: 'your_consumer_group_id',
  sessionTimeout: 15000,
  protocol: ['roundrobin'],
  fromOffset: 'latest'
};

const consumerGroup = new ConsumerGroup(consumerOptions, 'your_topic_name');

consumerGroup.on('message', function(message) {
  // 处理消息逻辑
  console.log(message);
});

consumerGroup.on('error', function(err) {
  // 错误处理逻辑
  console.error(err);
});