You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2020/04/02 23:54:00 UTC

[jira] [Commented] (KAFKA-9778) Add validateConnector functionality to the EmbeddedConnectCluster

    [ https://issues.apache.org/jira/browse/KAFKA-9778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074153#comment-17074153 ] 

ASF GitHub Bot commented on KAFKA-9778:
---------------------------------------

kkonstantine commented on pull request #8359: KAFKA-9778: Add validateConnector functionality to the EmbeddedConnectCluster
URL: https://github.com/apache/kafka/pull/8359
 
 
   
 
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


> Add validateConnector functionality to the EmbeddedConnectCluster
> -----------------------------------------------------------------
>
>                 Key: KAFKA-9778
>                 URL: https://issues.apache.org/jira/browse/KAFKA-9778
>             Project: Kafka
>          Issue Type: Improvement
>            Reporter: Daniel Osvath
>            Priority: Minor
>
> A validate endpoint should be added to enables the integration testing of validation functionalities, including validation success and assertion of specific error messages.
> This PR adds a method {{validateConnectorConfig}} to the {{EmbeddedConnectCluster}} that pings the {{/config/validate}} endpoint with the given configurations. [More about the endpoint here.|https://kafka.apache.org/documentation/#connect_rest]
> With this addition, the validations for the connector can be tested in a similar way integration tests currently use the {{configureConnector}} method, for ex: {{connect.configureConnector(CONNECTOR_NAME, props);}}. The validation call would look like: {{ConfigInfos validateResponse = connect.validateConnectorConfig(CONNECTOR_CLASS_NAME, props);}}.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)