public interface ConnectorClientConfigOverridePolicy extends org.apache.kafka.common.Configurable, AutoCloseable
An interface for enforcing a policy on overriding of client configs via the connector configs.
Common use cases are ability to provide principal per connector, sasl.jaas.config
and/or enforcing that the producer/consumer configurations for optimizations are within acceptable ranges.
Modifier and Type | Method and Description |
---|---|
List<org.apache.kafka.common.config.ConfigValue> |
validate(ConnectorClientConfigRequest connectorClientConfigRequest)
Worker will invoke this while constructing the producer for the SourceConnectors, DLQ for SinkConnectors and the consumer for the
SinkConnectors to validate if all of the overridden client configurations are allowed per the
policy implementation.
|
close
List<org.apache.kafka.common.config.ConfigValue> validate(ConnectorClientConfigRequest connectorClientConfigRequest)
connectorClientConfigRequest
- an instance of ConnectorClientConfigRequest
that provides the configs to overridden and
its context; never null
ConfigValue
instances that describe each client configuration in the request and includes an
error
if the configuration is not allowed by the policy; never null