How can I configure my connector to run in specific worker group in multicluster connect environment in distributed kafka connect?

As per the documentation, worker service is set to run before adding connectors. Suppose I am running worker-a with group.id “cluster-a” and worker-b with group.id “cluster-b” on three distributed VM’s. What is the configuration that makes connectors to choose their worker group.

Suppose I need to configure debezium mysql connector’s tasks to run on cluster-a and jdbc connector’s all tasks on cluster-b. How should I do it?

Thanks in advance.

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.