kafkajs消费者无法消费具有多个分区的主题

在创建消费者实例时，需要设置每个分区的起始偏移量。例如，对于具有两个分区的主题，您可以使用以下代码：

const { Kafka } = require('kafkajs')

const kafka = new Kafka({
  clientId: 'my-app',
  brokers: ['localhost:9092']
})

const consumer = kafka.consumer({ groupId: 'test-group' })

const run = async () => {
  await consumer.connect()
  await consumer.subscribe({ topic: 'my-topic', fromBeginning: true })

  await consumer.run({
    eachMessage: async ({ topic, partition, message }) => {
      console.log({
        value: message.value.toString(),
        partition,
        offset: message.offset,
      })
    },
    partitionsConsumedConcurrently: 1,
  })
}

run().catch(console.error)

在此示例中，我们设置 partitionsConsumedConcurrently 选项为1，这意味着每个消费者只会消费一个分区。然后，我们可以在 eachMessage 回调函数中处理每个分区的消息。