From b36a170aa3b2738177d7229859db765e0115385b Mon Sep 17 00:00:00 2001 From: Manyanda Chitimbo Date: Tue, 18 Apr 2023 13:36:56 +0200 Subject: [PATCH] MINOR: fix typos in MigrationClient, StandardAuthorizer, StandardAuthorizerData and KafkaConfigSchema files (#13593) Reviewers: Luke Chen --- .../main/java/org/apache/kafka/metadata/KafkaConfigSchema.java | 2 +- .../apache/kafka/metadata/authorizer/StandardAuthorizer.java | 2 +- .../kafka/metadata/authorizer/StandardAuthorizerData.java | 2 +- .../org/apache/kafka/metadata/migration/MigrationClient.java | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/metadata/src/main/java/org/apache/kafka/metadata/KafkaConfigSchema.java b/metadata/src/main/java/org/apache/kafka/metadata/KafkaConfigSchema.java index f7b7b0ed375..116dc7b2906 100644 --- a/metadata/src/main/java/org/apache/kafka/metadata/KafkaConfigSchema.java +++ b/metadata/src/main/java/org/apache/kafka/metadata/KafkaConfigSchema.java @@ -210,7 +210,7 @@ public class KafkaConfigSchema { Object value, ConfigSource source, Function converter) { - // Convert the value into a nulllable string suitable for storing in ConfigEntry. + // Convert the value into a nullable string suitable for storing in ConfigEntry. String stringValue = null; if (value != null) { if (value instanceof String) { diff --git a/metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java b/metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java index 197272a3e66..14d560ab1dc 100644 --- a/metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java +++ b/metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java @@ -55,7 +55,7 @@ public class StandardAuthorizer implements ClusterMetadataAuthorizer { public final static String ALLOW_EVERYONE_IF_NO_ACL_IS_FOUND_CONFIG = "allow.everyone.if.no.acl.found"; /** - * A future which is completed once we have loaded up to the initial high water mark. + * A future which is completed once we have loaded up to the initial high watermark. */ private final CompletableFuture initialLoadFuture = new CompletableFuture<>(); diff --git a/metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java b/metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java index c6d41a52da4..d0d15c5664f 100644 --- a/metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java +++ b/metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java @@ -525,7 +525,7 @@ public class StandardAuthorizerData { } // Check if the operation field matches. Here we hit a slight complication. // ACLs for various operations (READ, WRITE, DELETE, ALTER), "imply" the presence - // of DESCRIBE, even if it isn't explictly stated. A similar rule applies to + // of DESCRIBE, even if it isn't explicitly stated. A similar rule applies to // DESCRIBE_CONFIGS. // // But this rule only applies to ALLOW ACLs. So for example, a DENY ACL for READ diff --git a/metadata/src/main/java/org/apache/kafka/metadata/migration/MigrationClient.java b/metadata/src/main/java/org/apache/kafka/metadata/migration/MigrationClient.java index 1a03e0f2cd9..3af3cd10959 100644 --- a/metadata/src/main/java/org/apache/kafka/metadata/migration/MigrationClient.java +++ b/metadata/src/main/java/org/apache/kafka/metadata/migration/MigrationClient.java @@ -40,7 +40,7 @@ public interface MigrationClient { * Read or initialize the ZK migration leader state in ZK. If the ZNode is absent, the given {@code initialState} * will be written and subsequently returned with the zkVersion of the node. If the ZNode is present, it will be * read and returned. - * @param initialState An initial, emtpy, state to write to ZooKeeper for the migration state. + * @param initialState An initial, empty, state to write to ZooKeeper for the migration state. * @return The existing migration state, or the initial state given. */ ZkMigrationLeadershipState getOrCreateMigrationRecoveryState(ZkMigrationLeadershipState initialState);