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