Hi All,

we are running Kafka Connect in a distributed mode with Debezium (Mongo) as
a source and Confluent S3 connector as a sink. When add a new connector via
the REST API the connector is created in RUNNING state, but no tasks are
created for the connector. When we stop all workers and then start them
again, the tasks are created and everything runs as it should - until we
try to add another connector.

The issue is not caused by the connector plugins, because we see the same
behaviour for both Debezium and S3 connectors. Also in debug logs I can see
that Debezium is correctly returning a task configuration from
the Connector.taskConfigs() method.

Can somebody tell me what to do se we can add connectors without restarting
the workers?

Thanks,
Vit

Reply via email to