KafkaJS是否有一种方式让消费者获取最后n条消息？

可以通过使用KafkaJS的consumer.getTopicPartitions()方法来获取分区列表，然后通过consumer.offsetsForTopics()方法来获取分区的末尾偏移量。然后，使用consumer.subscribe()方法订阅每个分区，并使用consumer.seek()方法将偏移量设置为末尾偏移量减去n。最后，使用consumer.run()方法和消费者的回调函数来消费消息。

以下是代码示例：

const Kafka = require('kafkajs')

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

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

async function getLastNMessages(topic, n) {
  const partitions = await consumer.getTopicPartitions(topic)
  const endOffsets = await consumer.offsetsForTopics([{ topic, partitions }])

  await consumer.connect()
  await consumer.subscribe({ topic, fromBeginning: false })

  partitions.forEach(async partition => {
    const endOffset = endOffsets[topic][partition.toString()].offset
    const startOffset = Math.max(0, endOffset - n)
    await consumer.seek({ topic, partition, offset: startOffset })
  })

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

  await consumer.disconnect()
}

getLastNMessages('my-topic', 10)