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)