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

Unable to validate sink connectors without "topics" component which is not required

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 1.1.0
    • Fix Version/s: None
    • Component/s: KafkaConnect
    • Labels:
      None
    • Environment:
      CP4.1, Centos7

      Description

      The bug is happening when you try to create new connector through for example kafka-connect-ui.

      While both source and sink connectors were able to be validated through REST without "topics" as add-on with "connector.class" like this:

      PUT / http://connect-url:8083/connector-plugins/com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector/config/validate
      {
          "connector.class": "com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector",
      }

      In the new version of CP4.1 you still can validate source connectors but not sink connectors. If you want to validate sink connectors you need to add to request -> "topics" config, like:

      PUT / http://connect-url:8083/connector-plugins/com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector/config/validate
      {
          "connector.class": "com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector",
          "topics": "test-topic"
      }

      So there is a little missmatch of the ways how to validate connectors which I think happened accidentally.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                iMajna Ivan Majnarić
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated: