File tree Expand file tree Collapse file tree
clients/src/main/java/org/apache/kafka/clients Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -220,13 +220,13 @@ public synchronized int requestUpdateForNewTopics() {
220220 }
221221
222222 /**
223- * Request an update for the partition metadata iff we have seen a newer leader epoch. This is called by the client
223+ * Request an update for the partition metadata if and only if we have seen a newer leader epoch. This is called by the client
224224 * any time it handles a response from the broker that includes leader epoch, except for update via Metadata RPC which
225225 * follows a different code path ({@link #update}).
226226 *
227- * @param topicPartition
228- * @param leaderEpoch
229- * @return true if we updated the last seen epoch, false otherwise
227+ * @param topicPartition The partition for which to update the last seen leader epoch.
228+ * @param leaderEpoch The leader epoch received from the broker.
229+ * @return {@code true} if we updated the last seen epoch, {@code false} otherwise.
230230 */
231231 public synchronized boolean updateLastSeenEpochIfNewer (TopicPartition topicPartition , int leaderEpoch ) {
232232 Objects .requireNonNull (topicPartition , "TopicPartition cannot be null" );
You can’t perform that action at this time.
0 commit comments