Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

connector.client.config.policy - This will be an implementation of a new interface ConnectorClientConfigPolicy that will be introduced in the connect API. The default value will be null when not configured will simply ignore the provided overrides and hence the behavior continues to be backward compatible.

The overrides can be specified in the connector config by using the following prefixes

  • `producer.override` - Used for source connector
  • `consumer.override` - Used for Sink Connector
  • `admin.override` - Used for DLQ topic create in Sink Connector ( The KIP will also allow DLQ settings to be specified in the worker using `admin` prefix to be consistent with producer & consumer)

The administrator could either specify the fully qualified class name of the ConnectorClientConfigPolicy implementation or an alias (the alias is computed to be the prefix  on the interface name `ConnectorClientConfigPolicy` which is exactly how most of the existing connect plugins compute their alias).

...