Worker configuration parameters

bootstrap.servers
Initial hosts that act as the starting point for the Kafka Connect Worker to discover the full set of alive Kafka Brokers in the Kafka cluster.
key.converter
The name of the converter class used to deserialize Kafka message keys. Use the converter that corresponds to the serializers used by Producers.
value.converter
The name of the converter class used to deserialize Kafka message values. Use the converter that corresponds to the serializers used by Producers.
value.converter.schemas.enable
Enables (true) or disables (false) converter schemas.

Default: false.

group.id
For distributed mode only. Unique name for the cluster, used in forming the Connect cluster group.
Note: Must not conflict with consumer group IDs.
plugin.path
Set to a list of filesystem paths separated by commas (,). To enable class loading isolation for plugins (connectors, converters, and transformations). The list can include any combination of:
  • Directories that contain jars with plugins and their dependencies
  • Uber-jars with plugins and their dependencies
Note: When symlinks are specified, Kafka follows the link to discover dependencies or plugins.

For example, to look for plugins in two locations: plugin.path=,/usr/local/share/kafka/plugins,/opt/connectors.