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

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

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 1.1.0
    • None
    • connect
    • None
    • 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

              Unassigned Unassigned
              iMajna Ivan Majnarić
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated: