root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: fix typos in MigrationClient, StandardAuthorizer, StandardAuthorizerData and KafkaConfigSchema files (#13593) 

Reviewers: Luke Chen <showuon@gmail.com>
This commit is contained in:
Manyanda Chitimbo 2023-04-18 13:36:56 +02:00 committed by GitHub
parent 5e9d4de748
commit b36a170aa3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
metadata/src/main/java/org/apache/kafka/metadata/KafkaConfigSchema.java
View File

@ -210,7 +210,7 @@ public class KafkaConfigSchema {
Object value, Object value,
ConfigSource source, ConfigSource source,
Function<String, String> converter) { Function<String, String> 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; String stringValue = null;
if (value != null) { if (value != null) {
if (value instanceof String) { if (value instanceof String) {

2
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java
View File

@ -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"; 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<Void> initialLoadFuture = new CompletableFuture<>(); private final CompletableFuture<Void> initialLoadFuture = new CompletableFuture<>();

2
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java
View File

@ -525,7 +525,7 @@ public class StandardAuthorizerData {
} }
// Check if the operation field matches. Here we hit a slight complication. // Check if the operation field matches. Here we hit a slight complication.
// ACLs for various operations (READ, WRITE, DELETE, ALTER), "imply" the presence // 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. // DESCRIBE_CONFIGS.
// //
// But this rule only applies to ALLOW ACLs. So for example, a DENY ACL for READ // But this rule only applies to ALLOW ACLs. So for example, a DENY ACL for READ

2
metadata/src/main/java/org/apache/kafka/metadata/migration/MigrationClient.java
View File

@ -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} * 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 * will be written and subsequently returned with the zkVersion of the node. If the ZNode is present, it will be
* read and returned. * 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. * @return The existing migration state, or the initial state given.
*/ */
ZkMigrationLeadershipState getOrCreateMigrationRecoveryState(ZkMigrationLeadershipState initialState); ZkMigrationLeadershipState getOrCreateMigrationRecoveryState(ZkMigrationLeadershipState initialState);