You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Greg Harris (Jira)" <ji...@apache.org> on 2022/07/11 19:34:00 UTC

[jira] [Created] (KAFKA-14067) Sink connector override.consumer.group.id can conflict with worker group.id

Greg Harris created KAFKA-14067:
-----------------------------------

             Summary: Sink connector override.consumer.group.id can conflict with worker group.id
                 Key: KAFKA-14067
                 URL: https://issues.apache.org/jira/browse/KAFKA-14067
             Project: Kafka
          Issue Type: Bug
          Components: KafkaConnect
    Affects Versions: 2.3.0
            Reporter: Greg Harris


Currently there is a validation step for connector names which prevents sink connector consumer groups from colliding with the worker group.id.

There is currently no such validation for consumer.override.group.id that would prevent a conflicting connector from being configured, and so it is possible to misconfigure a connector in a way that may be damaging to the workers themselves.

Reproduction steps:
1. Configure a connect distributed cluster with a certain group.id in the worker config.
2. Configure a sink connector with consumer.override.group.id having the same value as in the worker config

Expected behavior:
1. An error is returned indicating that the consumer.override.group.id is invalid
2. The connector is not created or started

Actual behavior:
1. No error is returned, and the configuration is otherwise valid.
2. The connector is created and starts running.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)