Могу ли я получить нужные данные из последних данных Redis? - PullRequest
Новая
       13

Могу ли я получить нужные данные из последних данных Redis?

1 голос
/ 18 июня 2019

Я хочу знать смещение от данных Redis, например смещение в потребителе кафки. Приведенный ниже код - это код, который использует Kafka Consumer и смещение для импорта последних 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, как этот код?

Подобный метод был замечен в отсортированном наборе, но это была не та функция, которую я хотел. Я хочу сохранять данные журнала в реальном времени в Redis, и я хочу выводить их на последние 10 ~ 50 данных каждые 100 мс.

Есть ли способ получить его от Redis? Теперь я использую библиотеку салата.

1 Ответ

0 голосов
/ 18 июня 2019

С помощью функции pub и sub в Redis вы можете хранить свои данные в одном месте и извлекать эти данные через определенные интервалы.

Вы можете подписать свои данные на mongodb с помощью stackexcahnge.redis и отправить их своим клиентам с помощью API

Могут быть и другие решения, но я использую его таким образом и рекомендую

...