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)