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);