Kafka-Node:提交前一条消息后如何同步消费消息

const kafka = require('kafka-node');
const Consumer = kafka.Consumer;
const client = new kafka.KafkaClient({ kafkaHost: 'kafka-server:9092' });
const consumer = new Consumer(client, [{ topic: 'my-topic' }], { groupId: 'my-group' });

consumer.on('message', function (message) {
  console.log('Received message:', message);
});

consumer.on('message', function (message) {
  // 处理消息逻辑
  console.log('Received message:', message);
  // 同步消费消息后提交偏移量
  consumer.commit((error, data) => {
    if (error) {
      console.error('Error committing offset:', error);
    } else {
      console.log('Offset committed:', data);
    }
  });
});