【发布时间】:2019-10-31 18:50:44
【问题描述】:
我想知道 Redis 数据的偏移量,例如 kafka 消费者中的偏移量。 下面的代码是使用Kafka Consumer和offset导入最新n条数据的代码。
public ConsumerRecords<String, String> getLatestMessages() {
ConsumerRecords<String, String> messages = null;
consumer.seekToEnd(topics);
long endPosition = consumer.position(topicPartition);
long startPosition = endPosition - 10;
consumer.seek(topicPartition, startPosition);
messages = consumer.poll(Duration.ofMillis(100));
return messages;
}
我可以像这段代码一样从 Redis 获取 n 个数据吗?
在排序集中看到了类似的方法,但这不是我想要的功能。 我想将海量日志实时存储到Redis,我想每100ms将它们带到最新的10~50条数据。
有什么方法可以从 Redis 获取它? 现在我使用生菜库。
【问题讨论】: