Interface ConnectorClientConfigOverridePolicy
- All Superinterfaces:
AutoCloseable
,Configurable
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.
-
Method Summary
Modifier and TypeMethodDescriptionvalidate
(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.Methods inherited from interface java.lang.AutoCloseable
close
Methods inherited from interface org.apache.kafka.common.Configurable
configure
-
Method Details
-
validate
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. This would also be invoked during the validation of connector configs via the Rest API. If there are any policy violations, the connector will not be started.- Parameters:
connectorClientConfigRequest
- an instance ofConnectorClientConfigRequest
that provides the configs to overridden and its context; nevernull
- Returns:
- list of
ConfigValue
instances that describe each client configuration in the request and includes anerror
if the configuration is not allowed by the policy; never null
-