// GetConnectorPlugins returns a list of connector plugins installed in the Kafka Connect cluster.
// Note that the API only checks for connectors on the worker that handles the request,
// which means it is possible to see inconsistent results,
// especially during a rolling upgrade if you add new connector jars.
GetConnectorPlugins returns a list of connector plugins installed in the Kafka Connect cluster.
Note that the API only checks for connectors on the worker that handles the request,
which means it is possible to see inconsistent results,
especially during a rolling upgrade if you add new connector jars.
// GetConnectorPlugins returns a list of connector plugins installed in the Kafka Connect cluster . // Note that the API only checks for connectors on the worker that handles the request // which means it is possible to see inconsistent results // especially during a rolling upgrade if you add new connector jars .
func (c *Client) GetConnectorPlugins(clusterName string) (cp []ConnectorPlugin, err error) {
	if clusterName == "" {
		return nil, errRequired("clusterName")
	}
	path := fmt.Sprintf(pluginsPath, clusterName)
	resp, respErr := c.Do(http.MethodGet, path, "", nil)
	if respErr != nil {
		err = respErr
		return
	}
	err = c.ReadJSON(resp, &cp)
	return
}
func ( c * Client ) GetConnectorPlugins ( clusterName string ) ( cp [ ] ConnectorPlugin , err error ) { if clusterName == " " { return nil , errRequired ( " " ) } path := fmt . Sprintf ( pluginsPath , clusterName ) resp , respErr := c . Do ( http . MethodGet , path , " " , nil ) if respErr != nil { err = respErr return } err = c . ReadJSON ( resp , & cp ) return }
GetConnectorPlugins returns a list of connector plugins installed in the Kafka Connect cluster.
GetConnectorPlugins returns a list of connector plugins installed in the Kafka Connect cluster .
// # List available connector plugins // GET /api/proxy-connect/(string: clusterName)/connector-plugins