public interface ConnectorClientConfigOverridePolicy extends org.apache.kafka.common.Configurable, AutoCloseable
Common use cases are ability to provide principal per connector,
and/or enforcing that the producer/consumer configurations for optimizations are within acceptable ranges.
|Modifier and Type||Method and Description|
Workers will invoke this before configuring per-connector Kafka admin, producer, and consumer client instances to validate if all the overridden client configurations are allowed per the policy implementation.
List<org.apache.kafka.common.config.ConfigValue> validate(ConnectorClientConfigRequest connectorClientConfigRequest)
If there are any policy violations, the connector will not be started.
connectorClientConfigRequest- an instance of
ConnectorClientConfigRequestthat provides the configs to be overridden and its context; never
ConfigValueinstances that describe each client configuration in the request and includes an
errorif the configuration is not allowed by the policy; never null