diff --git a/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java b/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java index 692847a8b1553..88d455b5c9ec0 100644 --- a/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java +++ b/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java @@ -1479,7 +1479,7 @@ public ClientRequest newClientRequest(String nodeId, // visible for testing int nextCorrelationId() { if (SaslClientAuthenticator.isReserved(correlation)) { - // the numeric overflow is fine as negative values is acceptable + // the numeric overflow is fine as negative values are acceptable correlation = SaslClientAuthenticator.MAX_RESERVED_CORRELATION_ID + 1; } return correlation++; diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterResult.java b/clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterResult.java index 69782d5c9c333..54295157ea77b 100644 --- a/clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterResult.java +++ b/clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterResult.java @@ -53,7 +53,7 @@ public KafkaFuture> nodes() { /** * Returns a future which yields the current controller node. *

- * When using {@link AdminClientConfig#BOOTSTRAP_SERVERS_CONFIG}, the controller refer to a random broker. + * When using {@link AdminClientConfig#BOOTSTRAP_SERVERS_CONFIG}, the controller refers to a random broker. * When using {@link AdminClientConfig#BOOTSTRAP_CONTROLLERS_CONFIG}, it refers to the current voter leader. */ public KafkaFuture controller() { diff --git a/clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java b/clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java index e271cd99c4cd0..a1d4cd94241ec 100644 --- a/clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java +++ b/clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java @@ -150,7 +150,7 @@ public AbstractConfig(ConfigDef definition, Map originals, boolean doLog) } /** - * Called directly after user configs got parsed (and thus default values is not set). + * Called directly after user configs got parsed (and thus default values are not set). * This allows to check user's config. * * @param parsedValues unmodifiable map of current configuration diff --git a/clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java b/clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java index 22b00fa0c3d00..15c3e0e12fd58 100644 --- a/clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java +++ b/clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java @@ -519,7 +519,7 @@ public Map parse(Map props) { List undefinedConfigKeys = undefinedDependentConfigs(); if (!undefinedConfigKeys.isEmpty()) { String joined = undefinedConfigKeys.stream().map(String::toString).collect(Collectors.joining(",")); - throw new ConfigException("Some configurations in are referred in the dependents, but not defined: " + joined); + throw new ConfigException("Some configurations are referred in the dependents but not defined: " + joined); } // parse all known keys Map values = new HashMap<>(); diff --git a/clients/src/main/java/org/apache/kafka/common/metrics/PluginMetrics.java b/clients/src/main/java/org/apache/kafka/common/metrics/PluginMetrics.java index 5edd9462b80fd..ba2228ab69dc8 100644 --- a/clients/src/main/java/org/apache/kafka/common/metrics/PluginMetrics.java +++ b/clients/src/main/java/org/apache/kafka/common/metrics/PluginMetrics.java @@ -22,7 +22,7 @@ /** * This allows plugins to register metrics and sensors. - * Any metrics registered by the plugin are automatically removed when the plugin closed. + * Any metrics registered by the plugin are automatically removed when the plugin is closed. */ public interface PluginMetrics {