Versions Compared

Key

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

...

Also, the distributed worker configuration will be changed to recognize additional optional properties that match the following patterns, and to pass them (without the prefix) to the new topic requests created by the Connect distributed worker when it attempts to create the internal topics:

Property pattern

Type

Default

Possible Values

Description

config.storage.<topic-specific-setting>
severalbroker value
Additional topic-specific settings used when creating the internal Kafka topic where Connect stores connector configurations. Here "<topic-specific-setting>" corresponds to any of the Kafka topic-level configurations for the version of the Kafka broker where the topic should be created.
offset.storage.<topic-specific-setting>
severalbroker value
Additional topic-specific settings used when creating the internal Kafka topic where Connect stores source offsets for source connectors. Here "<topic-specific-setting>" corresponds to any of the Kafka topic-level configurations for the version of the Kafka broker where the topic should be created.
status.storage.<topic-specific-setting>
severalbroker value
Additional topic-specific settings used when creating the internal Kafka topic where Connect stores connector and task statuses. Here "<topic-specific-setting>" corresponds to any of the Kafka topic-level configurations for the version of the Kafka broker where the topic should be created.

These additional properties (without the prefix) will be passed to the new topic requests created by the Connect worker when it attempts to create the internal topics.


NOTE: This proposal This proposal does not change any other behavior of how the Connect worker creates internal topics or uses the properties related to internal topics. This proposal also does not affect Connect standalone behavior.

...