Skip to content

Commit 6d548f0

Browse files
committed
fix java document
1 parent 5988fa6 commit 6d548f0

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -237,7 +237,7 @@ public class KafkaStreams implements AutoCloseable {
237237
* </li>
238238
* <li>
239239
* REBALANCING state will transit to RUNNING if all of its threads are in RUNNING state
240-
* (Note: a thread transits to RUNNING state, if all active tasks got restored are are ready for processing.
240+
* (Note: a thread transits to RUNNING state, if all active tasks got restored are ready for processing.
241241
* Standby tasks are not considered.)
242242
* </li>
243243
* <li>
@@ -1678,7 +1678,7 @@ public synchronized boolean close(final CloseOptions options) throws IllegalArgu
16781678
* Shutdown this {@code KafkaStreams} by signaling all the threads to stop, and then wait up to the timeout for the
16791679
* threads to join.
16801680
* @param options contains timeout to specify how long to wait for the threads to shut down, and a flag
1681-
* {@link org.apache.kafka.streams.CloseOptions.GroupMembershipOperation.LEAVE_GROUP} to
1681+
* {@link org.apache.kafka.streams.CloseOptions.GroupMembershipOperation#LEAVE_GROUP} to
16821682
* trigger consumer leave call
16831683
* @return {@code true} if all threads were successfully stopped&mdash;{@code false} if the timeout was reached
16841684
* before all threads stopped

0 commit comments

Comments
 (0)