public interface MetadataServer
extends org.apache.kafka.common.Configurable, java.io.Closeable
Modifier and Type | Method and Description |
---|---|
default java.lang.String |
providerName() |
void |
start(io.confluent.security.authorizer.Authorizer embeddedAuthorizer,
AuthStore authStore,
org.apache.kafka.common.security.auth.AuthenticateCallbackHandler authenticateCallbackHandler)
Starts metadata server.
|
void start(io.confluent.security.authorizer.Authorizer embeddedAuthorizer, AuthStore authStore, org.apache.kafka.common.security.auth.AuthenticateCallbackHandler authenticateCallbackHandler)
This method is invoked only after the reader associated with the provided `authStore` is
initialized and the local cache is populated with existing entries. The metadata server
can use AuthStore.writer()
to update the store.
embeddedAuthorizer
- An embedded cross-component authorizer that can be used to authorize any action.authStore
- An instance of AuthStore that can be used to read current role bindings,
user metadata etc. from an in-memory cache that is kept up-to-date by the embedded
authorizer.authenticateCallbackHandler
- Authentication callback handlers, e.g. for LDAP authenticationdefault java.lang.String providerName()