[KAFKA-14015] ConfigProvider with ttl fails to restart tasks

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.4.0
• Component/s: connect
• Assignee: Yash Mayya
• Reporter: Ross Lawley
• Created: 21/Jun/22 17:07
• Updated: 06/Sep/22 13:06
• Resolved: 06/Sep/22 13:06

Description

According to the KIP-297:

• When the Herder receives the onChange() call, it will check a new connector configuration property config.reload.action which can be one of the following:
  • The value restart, which means to schedule a restart of the Connector and all its Tasks. This will be the default.
  • The value none, which means to do nothing.

However, the restartConnector method only restarts the connector and does not restart any tasks.  Suggest calling restartConnectorAndTasks instead.

The result is changed configurations provided by the ConfigProvider are not picked up and existing tasks continue to use outdated configuration.

Issue Links

• links to: GitHub Pull Request #12568