public interface Provider
extends org.apache.kafka.common.Configurable, java.io.Closeable
Modifier and Type | Method and Description |
---|---|
default boolean |
needsLicense()
Returns true if this is a proprietary provider that requires a license
|
java.lang.String |
providerName()
Returns the name of this provider.
|
default java.util.concurrent.CompletionStage<java.lang.Void> |
start(java.util.Map<java.lang.String,?> interBrokerListenerConfigs)
Starts a provider and returns a future that is completed when the provider is ready.
|
boolean |
usesMetadataFromThisKafkaCluster()
Returns true if this provider uses metadata from a Kafka topic on this cluster.
|
default java.util.concurrent.CompletionStage<java.lang.Void> start(java.util.Map<java.lang.String,?> interBrokerListenerConfigs)
interBrokerListenerConfigs
- Client configs for using inter-broker listener
For brokers that host metadata service, these client configs may be used to access metadata
topic if metadata client configs are not explicitly overridden. This avoids the need for
redundant configs for brokers in the metadata cluster.java.lang.String providerName()
boolean usesMetadataFromThisKafkaCluster()
default boolean needsLicense()