From adad948ad55f7a1f2bdd9670776601be7af7e5ef Mon Sep 17 00:00:00 2001 From: ableegoldman Date: Mon, 1 Jun 2020 10:40:51 -0700 Subject: [PATCH] add note to javadocs --- streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java | 1 + 1 file changed, 1 insertion(+) diff --git a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java index 43a53415cd57a..35d6d16c0ff88 100644 --- a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java +++ b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java @@ -1225,6 +1225,7 @@ public Set localThreadsMetadata() { * of invocation to once every few seconds. * * @return map of store names to another map of partition to {@link LagInfo}s + * @throws StreamsException if the admin client request throws exception */ public Map> allLocalStorePartitionLags() { final long latestSentinel = -2L;