0

我是 Kafka 和 KafkaJS 的新手。

我试图找到一种方法来获取发送到某个主题的最后 n 条消息，而不是获取该主题的所有未使用的消息。

例如，我有一个生产者每秒产生 1 条消息并让它等待 5 秒。

然后，当我启动消费者时，消费者会收到所有 5 条消息。（只有 1 个消费者在运行，1 个组，1 个分区，与生产者相同的主题）。

KafkaJS 上是否有配置仅获取最后 n 条生成的消息？

4

1 回答 1

1

您可以轮询单个记录，或者事先列出主题的偏移量。

然后你可以seek一个消费者并high_offset - N从那里开始轮询

于 2021-10-04T19:14:05.077 回答