public class MdsAclMigration
extends java.lang.Object
Constructor and Description |
---|
MdsAclMigration(java.lang.String clusterId,
java.util.function.Supplier<java.lang.Integer> brokerIdSupplier) |
Modifier and Type | Method and Description |
---|---|
void |
migrate(java.util.Map<java.lang.String,?> configs,
org.apache.kafka.server.authorizer.Authorizer aclAuthorizer,
org.apache.kafka.clients.admin.ConfluentAdmin mdsAdminClient) |