THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Current state: Under Discussion
Discussion thread: here [Change the link from the KIP proposal email archive to your own email thread]
JIRA:
| Jira | ||||||
|---|---|---|---|---|---|---|
|
...
The following existing metrics will be modified:
MBean Name | Change | New Range of Values |
|---|---|---|
| kafka.connect:type=connector-metrics,name=status,connector=([-.\w]+) | Add "restarting" as a possible value for this metric. | one of: "unassigned", "running", "paused", "failed", "restarting" or "destroyed" |
| kafka.connect:type=connector-task-metrics,name=status,connector=([-.\w]+) | Add "restarting" as a possible value for this metric. | one of: "unassigned", "running", "paused", "failed", "restarting" or "destroyed" |
Proposed Changes
The Connect distributed and standalone runtimes will be changed to support restarting a combination of the Connector and Task instances for a named connector, based upon the new query parameters. The restart requests will result in the state of each targeted Connector and Task instances being initially set to RESTARTING, and will reuse the worker’s existing logic to stop and (asynchronously) start the Connector and Task instances. That existing logic does not wait for the instances to complete their startup, and it will transition this state to RUNNING when the instance is actually started.
...