Package org.apache.kafka.connect.connector.policy

Interface ConnectorClientConfigOverridePolicy

All Superinterfaces:
AutoCloseable, Configurable
public interface ConnectorClientConfigOverridePolicy extends 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.

  • Method Summary

    Modifier and Type
    Method
    Description
    List<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.

    Methods inherited from interface java.lang.AutoCloseable

    close

    Methods inherited from interface org.apache.kafka.common.Configurable

    configure

  • Method Details

    • validate

      List<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. This would also be invoked during the validate of connector configs via the Rest API. If there are any policy violations, the connector will not be started.
      Parameters:
      connectorClientConfigRequest - an instance of ConnectorClientConfigRequest that provides the configs to overridden and its context; never null
      Returns:
      list of 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