From 3d8506a3ac5e4176ea1f2f0be97bef2712f46464 Mon Sep 17 00:00:00 2001 From: Michal Borowiecki Date: Fri, 21 Apr 2017 13:25:12 -0700 Subject: [PATCH] KAFKA-5090: Fix Kafka Streams SessionStore.findSessions javadoc broken Author: mihbor Reviewers: Matthias J. Sax, Guozhang Wang Closes #2874 from mihbor/patch-1 --- .../java/org/apache/kafka/streams/state/SessionStore.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java b/streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java index 16fa27112da8..8ae5c063ff8f 100644 --- a/streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java +++ b/streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java @@ -27,8 +27,8 @@ public interface SessionStore extends StateStore, ReadOnlySessionStore { /** - * Fetch any sessions with the matching key and the sessions end is &le earliestEndTime and the sessions - * start is &ge latestStartTime + * Fetch any sessions with the matching key and the sessions end is ≥ earliestSessionEndTime and the sessions + * start is ≤ latestSessionStartTime */ KeyValueIterator, AGG> findSessions(final K key, long earliestSessionEndTime, final long latestSessionStartTime);