Skip to content

Support new restart semantics in Kafka 3.0 #102

Description

@gunnarmorling

Kafka Connect 3.0 has the ability to restart all the failed tasks of a connector:

POST /connectors/{name}/restart?includeTasks=<true|false>&onlyFailed=<true|false>

More info:

The existing kcctl restart connector <name> command should be enhanced with a parameter for leveraging this: --tasks=<all|failed>. Using these parameters with Connect < 3.0 should be ignored but log a warning. Completion of those options should not be done for Connect 3.0.

Thinking more about it, we actually could support this for any KC version, using the new (and more efficient API) if available, otherwise falling back to multiple separate API calls.

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Fields

No fields configured for issues without a type.

Projects

No projects

Milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions