Kafka Connect:在分布式模式下创建新连接器就是创建新组

我目前正在使用confluent 3.0.1平台。我试图在两个不同的工作人员上创建2个连接器,但尝试创建新连接器会为其创建一个新组。

Two connectors were created using below details:

1) POST http://devmetric.com:8083/connectors

{
    "name": "connector1",
    "config": {
        "connector.class": "com.xxx.kafka.connect.sink.DeliverySinkConnector",
        "tasks.max": "1",
        "topics": "dev.ps_primary_delivery",
        "elasticsearch.cluster.name": "ad_metrics_store",
        "elasticsearch.hosts": "devkafka1.com:9300",
        "elasticsearch.bulk.size": "100",
        "tenants": "tenant1"
    }
}

2) POST http://devkafka01.com:8083/connectors

{
    "name": "connector2",
    "config": {
        "connector.class": "com.xxx.kafka.connect.sink.DeliverySinkConnector",
        "tasks.max": "1",
        "topics": "dev.ps_primary_delivery",
        "elasticsearch.cluster.name": "ad_metrics_store",
        "elasticsearch.hosts": "devkafka.com:9300",
        "elasticsearch.bulk.size": "100",
        "tenants": "tenant1"
    }
}

但它们都是在不同的组id下创建的。在此之后,我查询了现有的组。

$ sh ./bin/kafka-consumer-groups --bootstrap-server devmetric.com:9091  --new-consumer  --list

Result was:
connect-connector2
connect-connector1

这些组是由Kafka connect自动创建的,不是由我提供的。我提供了不同的组。worker.properties中的id。但我希望两个连接器都在同一组下,以便它们并行工作以共享消息。到目前为止,我有100万个关于“dev.ps_primary_delivery”主题的数据,我希望两个连接器都能获得50万个数据。

请让我知道怎么做。