有没有办法让消费者使用 KafkaJS 获取最后一条消息？
Is there a way for the consumer the get the n last messages with KafkaJS?
我是 Kafka 和 KafkaJS 的新手。
我正在尝试找到一种方法来获取发送到主题的最后 n 条消息，而不是获取该主题的所有未使用的消息。
比如我有一个生产者，每秒生产1条消息，让它等待5秒。
然后，当我启动消费者时，消费者会收到所有 5 条消息。
（只有 1 个消费者 运行，1 个组，1 个分区，与生产者相同的主题）。
KafkaJS 是否有配置只获取最后 n 个生成的消息？
您可以轮询单个记录，或者预先 list the offsets of the topic。
然后你可以seek a consumer到high_offset - N并从那里开始轮询
我是 Kafka 和 KafkaJS 的新手。
我正在尝试找到一种方法来获取发送到主题的最后 n 条消息，而不是获取该主题的所有未使用的消息。
比如我有一个生产者，每秒生产1条消息，让它等待5秒。
然后，当我启动消费者时，消费者会收到所有 5 条消息。 （只有 1 个消费者 运行，1 个组，1 个分区，与生产者相同的主题）。
KafkaJS 是否有配置只获取最后 n 个生成的消息？
您可以轮询单个记录，或者预先 list the offsets of the topic。
然后你可以seek a consumer到high_offset - N并从那里开始轮询