From 08c2f4a0b1e5e70a3ba0fe4818457de7f7cac1e9 Mon Sep 17 00:00:00 2001 From: Chia-Ping Tsai Date: Thu, 6 Apr 2023 01:19:57 +0800 Subject: [PATCH] MINOR: fix invalid usage in java docs --- .../main/java/org/apache/kafka/server/util/Scheduler.java | 2 +- .../main/java/org/apache/kafka/streams/query/Position.java | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/server-common/src/main/java/org/apache/kafka/server/util/Scheduler.java b/server-common/src/main/java/org/apache/kafka/server/util/Scheduler.java index 3468e2854241c..fde3a97914017 100644 --- a/server-common/src/main/java/org/apache/kafka/server/util/Scheduler.java +++ b/server-common/src/main/java/org/apache/kafka/server/util/Scheduler.java @@ -50,7 +50,7 @@ default ScheduledFuture scheduleOnce(String name, Runnable task, long delayMs * @param name The name of this task * @param task The task to run * @param delayMs The number of milliseconds to wait before the first execution - * @param periodMs The period in milliseconds with which to execute the task. If < 0 the task will execute only once. + * @param periodMs The period in milliseconds with which to execute the task. If < 0 the task will execute only once. * @return A Future object to manage the task scheduled. */ ScheduledFuture schedule(String name, Runnable task, long delayMs, long periodMs); diff --git a/streams/src/main/java/org/apache/kafka/streams/query/Position.java b/streams/src/main/java/org/apache/kafka/streams/query/Position.java index c481456511033..089bca12cdc56 100644 --- a/streams/src/main/java/org/apache/kafka/streams/query/Position.java +++ b/streams/src/main/java/org/apache/kafka/streams/query/Position.java @@ -57,7 +57,7 @@ public static Position emptyPosition() { } /** - * Create a new Position and populate it with a mapping of topic -> partition -> offset. + * Create a new Position and populate it with a mapping of topic -> partition -> offset. *

* Note, the resulting Position does not share any structure with the provided map, so * subsequent changes to the map or Position will not affect the other. @@ -95,7 +95,7 @@ public Position copy() { /** * Merges the provided Position into the current instance. *

- * If both Positions contain the same topic -> partition -> offset mapping, the resulting + * If both Positions contain the same topic -> partition -> offset mapping, the resulting * Position will contain a mapping with the larger of the two offsets. */ public Position merge(final Position other) { @@ -127,7 +127,7 @@ public Set getTopics() { } /** - * Return the partition -> offset mapping for a specific topic. + * Return the partition -> offset mapping for a specific topic. */ public Map getPartitionPositions(final String topic) { final ConcurrentHashMap bound = position.get(topic);