From 8614e15a28d60ec738a18518c1bf2ea75dc50471 Mon Sep 17 00:00:00 2001 From: Maros Orsak Date: Thu, 24 Jul 2025 13:05:07 +0200 Subject: [PATCH] MINOR: typo in javadoc (#20113) This PR fixes a typo in the Javadoc. --------- Signed-off-by: see-quick Reviewers: Luke Chen --- .../clients/consumer/internals/events/CompletableEvent.java | 2 +- release/templates.py | 2 +- .../src/main/java/org/apache/kafka/streams/KafkaStreams.java | 2 +- .../src/main/java/org/apache/kafka/streams/StreamsConfig.java | 2 +- tests/kafkatest/services/security/kafka_acls.py | 4 ++-- tools/src/test/java/org/apache/kafka/tools/JmxToolTest.java | 2 +- 6 files changed, 7 insertions(+), 7 deletions(-) diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CompletableEvent.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CompletableEvent.java index 20231b0f99a..bb59a4ec7e3 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CompletableEvent.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CompletableEvent.java @@ -45,7 +45,7 @@ public interface CompletableEvent { * (if applicable) is passed to {@link CompletableFuture#complete(Object)}. In the case where the generic * bound type is specified as {@link Void}, {@code null} is provided. *
  • - * Error: when the the event logic generates an error, the error is passed to + * Error: when the event logic generates an error, the error is passed to * {@link CompletableFuture#completeExceptionally(Throwable)}. *
    • *
  • diff --git a/release/templates.py b/release/templates.py index 06a142e0222..e067f1eb475 100644 --- a/release/templates.py +++ b/release/templates.py @@ -70,7 +70,7 @@ If any of these are missing, see https://cwiki.apache.org/confluence/display/KAF Some of these may be used from these previous settings loaded from {prefs_file}: {prefs} -Do you have all of of these setup?""" +Do you have all of these setup?""" def release_announcement_email(release_version, contributors): 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 b3723ef447d..384a6eeccd2 100644 --- a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java +++ b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java @@ -236,7 +236,7 @@ public class KafkaStreams implements AutoCloseable { *
    • *
  • * REBALANCING state will transit to RUNNING if all of its threads are in RUNNING state - * (Note: a thread transits to RUNNING state, if all active tasks got restored are are ready for processing. + * (Note: a thread transits to RUNNING state, if all active tasks got restored are ready for processing. * Standby tasks are not considered.) *
    • *
  • diff --git a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java index 6364e7e9126..48822a996d5 100644 --- a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java +++ b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java @@ -1859,7 +1859,7 @@ public class StreamsConfig extends AbstractConfig { if (segmentSize < batchSize) { throw new IllegalArgumentException(String.format( - "Specified topic segment size %d is is smaller than the configured producer batch size %d, this will cause produced batch not able to be appended to the topic", + "Specified topic segment size %d is smaller than the configured producer batch size %d, this will cause produced batch not able to be appended to the topic", segmentSize, batchSize )); diff --git a/tests/kafkatest/services/security/kafka_acls.py b/tests/kafkatest/services/security/kafka_acls.py index 8c6f946b109..ec7f2a63a35 100644 --- a/tests/kafkatest/services/security/kafka_acls.py +++ b/tests/kafkatest/services/security/kafka_acls.py @@ -27,7 +27,7 @@ class ACLs: :param additional_cluster_operations_to_grant may be set to ['Alter', 'Create'] if the cluster is secured since these are required to create SCRAM credentials and topics, respectively :param security_protocol set it to explicitly determine whether we use client or broker credentials, otherwise - we use the the client security protocol unless inter-broker security protocol is PLAINTEXT, in which case we use PLAINTEXT. + we use the client security protocol unless inter-broker security protocol is PLAINTEXT, in which case we use PLAINTEXT. Then we use the broker's credentials if the selected security protocol matches the inter-broker security protocol, otherwise we use the client's credentials. """ @@ -49,7 +49,7 @@ class ACLs: :param additional_cluster_operations_to_remove may be set to ['Alter', 'Create'] if the cluster is secured since these are required to create SCRAM credentials and topics, respectively :param security_protocol set it to explicitly determine whether we use client or broker credentials, otherwise - we use the the client security protocol unless inter-broker security protocol is PLAINTEXT, in which case we use PLAINTEXT. + we use the client security protocol unless inter-broker security protocol is PLAINTEXT, in which case we use PLAINTEXT. Then we use the broker's credentials if the selected security protocol matches the inter-broker security protocol, otherwise we use the client's credentials. """ diff --git a/tools/src/test/java/org/apache/kafka/tools/JmxToolTest.java b/tools/src/test/java/org/apache/kafka/tools/JmxToolTest.java index 114df5329ba..6c93ca69b23 100644 --- a/tools/src/test/java/org/apache/kafka/tools/JmxToolTest.java +++ b/tools/src/test/java/org/apache/kafka/tools/JmxToolTest.java @@ -55,7 +55,7 @@ public class JmxToolTest { public static void beforeAll() throws Exception { int port = findRandomOpenPortOnAllLocalInterfaces(); jmxUrl = format("service:jmx:rmi:///jndi/rmi://:%d/jmxrmi", port); - // explicitly set the hostname returned to the the clients in the remote stub object + // explicitly set the hostname returned to the clients in the remote stub object // when connecting to a multi-homed machine using RMI, the wrong address may be returned // by the RMI registry to the client, causing the connection to the RMI server to timeout System.setProperty("java.rmi.server.hostname", "localhost");