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 7f184b6c72c91..7d3b713e00ed6 100644 --- a/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java +++ b/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java @@ -1761,7 +1761,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 125392c20af9e..9e11320d358a3 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 @@ -55,7 +55,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 f6581810384a3..6937d3102c162 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 @@ -152,7 +152,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 5efcfec246916..3554fdf13be04 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 @@ -521,7 +521,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 to 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 9633e90745f7b..36df636fb2c3c 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 @@ -24,7 +24,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. */ @InterfaceAudience.Public public interface PluginMetrics {