Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-14067

Sink connector override.consumer.group.id can conflict with worker group.id

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • 2.3.0
    • 3.7.0
    • connect
    • None

    Description

      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.

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              gharris1727 Greg Harris
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: