fix(kafka): resolves kafka connect catalog failure

pkg/kafka/kafkaconnect.go

@@ -188,7 +188,7 @@ func (c *connectImpl) GetInfo(_ context.Context) (map[string]interface{}, error)
 // ListConnectors lists all connectors
 func (c *connectImpl) ListConnectors(_ context.Context) ([]string, error) {
 	// Make request
-	resp, err := c.client.DefaultAPI.ListConnectors(c.ctx).Execute()
+	_, resp, err := c.client.DefaultAPI.ListConnectors(c.ctx).Execute()
 	if err != nil {
 		return nil, fmt.Errorf("failed to list connectors: %w", err)
 	}
@@ -243,7 +243,7 @@ func (c *connectImpl) CreateConnector(_ context.Context, name string, config map
 	payload.SetConfig(config)
 
 	// Make request
-	resp, err := c.client.DefaultAPI.CreateConnector(c.ctx).CreateConnectorRequest(payload).Execute()
+	_, resp, err := c.client.DefaultAPI.CreateConnector(c.ctx).CreateConnectorRequest(payload).Execute()
 	if err != nil {
 		return nil, fmt.Errorf("failed to create connector: %w", err)
 	}
@@ -294,7 +294,7 @@ func (c *connectImpl) UpdateConnector(_ context.Context, name string, config map
 	}
 
 	// Make request
-	resp, err := c.client.DefaultAPI.PutConnectorConfig(c.ctx, name).RequestBody(stringConfig).Execute()
+	_, resp, err := c.client.DefaultAPI.PutConnectorConfig(c.ctx, name).RequestBody(stringConfig).Execute()
 	if err != nil {
 		return nil, fmt.Errorf("failed to update connector: %w", err)
 	}
@@ -367,7 +367,7 @@ func (c *connectImpl) ResumeConnector(_ context.Context, name string) error {
 // RestartConnector restarts a connector
 func (c *connectImpl) RestartConnector(_ context.Context, name string) error {
 	// Make request
-	_, err := c.client.DefaultAPI.RestartConnector(c.ctx, name).Execute()
+	_, _, err := c.client.DefaultAPI.RestartConnector(c.ctx, name).Execute()
 	if err != nil {
 		return fmt.Errorf("failed to restart connector: %w", err)
 	}
@@ -378,10 +378,21 @@ func (c *connectImpl) RestartConnector(_ context.Context, name string) error {
 // GetConnectorConfig gets the configuration of a connector
 func (c *connectImpl) GetConnectorConfig(_ context.Context, name string) (map[string]string, error) {
 	// Make request
-	config, _, err := c.client.DefaultAPI.GetConnectorConfig(c.ctx, name).Execute()
+	_, resp, err := c.client.DefaultAPI.GetConnectorConfig(c.ctx, name).Execute()
 	if err != nil {
 		return nil, fmt.Errorf("failed to get connector config: %w", err)
 	}
+	defer func() { _ = resp.Body.Close() }()
+
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return nil, fmt.Errorf("failed to read response: %w", err)
+	}
+
+	var config map[string]string
+	if err := json.Unmarshal(body, &config); err != nil {
+		return nil, fmt.Errorf("failed to parse connector config: %w", err)
+	}
 
 	return config, nil
 }
@@ -532,7 +543,7 @@ func (c *connectImpl) ValidateConfig(_ context.Context, pluginClass string, conf
 	}
 
 	// Make request
-	_, resp, err := c.client.DefaultAPI.ValidateConfigs(c.ctx, pluginClass).RequestBody(stringConfig).Execute()
+	resp, err := c.client.DefaultAPI.ValidateConfigs(c.ctx, pluginClass).RequestBody(stringConfig).Execute()
 	if err != nil {
 		return nil, fmt.Errorf("failed to validate connector config: %w", err)
 	}

sdk/sdk-kafkaconnect/.gitignore

@@ -0,0 +1,24 @@
+# Compiled Object files, Static and Dynamic libs (Shared Objects)
+*.o
+*.a
+*.so
+
+# Folders
+_obj
+_test
+
+# Architecture specific extensions/prefixes
+*.[568vq]
+[568vq].out
+
+*.cgo1.go
+*.cgo2.c
+_cgo_defun.c
+_cgo_gotypes.go
+_cgo_export.*
+
+_testmain.go
+
+*.exe
+*.test
+*.prof

sdk/sdk-kafkaconnect/.openapi-generator-ignore

@@ -0,0 +1,23 @@
+# OpenAPI Generator Ignore
+# Generated by openapi-generator https://github.com/openapitools/openapi-generator
+
+# Use this file to prevent files from being overwritten by the generator.
+# The patterns follow closely to .gitignore or .dockerignore.
+
+# As an example, the C# client generator defines ApiClient.cs.
+# You can make changes and tell OpenAPI Generator to ignore just this file by uncommenting the following line:
+#ApiClient.cs
+
+# You can match any string of characters against a directory, file or extension with a single asterisk (*):
+#foo/*/qux
+# The above matches foo/bar/qux and foo/baz/qux, but not foo/bar/baz/qux
+
+# You can recursively match patterns against a directory, file or extension with a double asterisk (**):
+#foo/**/qux
+# This matches foo/bar/qux, foo/baz/qux, and foo/bar/baz/qux
+
+# You can also negate patterns with an exclamation (!).
+# For example, you can ignore all files in a docs folder with the file extension .md:
+#docs/*.md
+# Then explicitly reverse the ignore rule for a single file:
+#!docs/README.md

sdk/sdk-kafkaconnect/.openapi-generator/FILES

@@ -0,0 +1,55 @@
+.gitignore
+.openapi-generator-ignore
+.travis.yml
+README.md
+api/openapi.yaml
+api_default.go
+client.go
+configuration.go
+docs/ConfigFieldDefinition.md
+docs/ConfigInfo.md
+docs/ConfigInfos.md
+docs/ConfigKeyInfo.md
+docs/ConfigValueInfo.md
+docs/ConnectorInfo.md
+docs/ConnectorOffset.md
+docs/ConnectorOffsets.md
+docs/ConnectorState.md
+docs/ConnectorStateInfo.md
+docs/ConnectorTaskId.md
+docs/CreateConnectorRequest.md
+docs/DefaultAPI.md
+docs/ErrorMessage.md
+docs/FunctionMeshConnectorDefinition.md
+docs/Message.md
+docs/PluginInfo.md
+docs/ServerInfo.md
+docs/TaskInfo.md
+docs/TaskState.md
+docs/WorkerStatus.md
+git_push.sh
+go.mod
+go.sum
+model_config_field_definition.go
+model_config_info.go
+model_config_infos.go
+model_config_key_info.go
+model_config_value_info.go
+model_connector_info.go
+model_connector_offset.go
+model_connector_offsets.go
+model_connector_state.go
+model_connector_state_info.go
+model_connector_task_id.go
+model_create_connector_request.go
+model_error_message.go
+model_function_mesh_connector_definition.go
+model_message.go
+model_plugin_info.go
+model_server_info.go
+model_task_info.go
+model_task_state.go
+model_worker_status.go
+response.go
+test/api_default_test.go
+utils.go

sdk/sdk-kafkaconnect/.openapi-generator/VERSION

@@ -0,0 +1 @@
+7.12.0

sdk/sdk-kafkaconnect/.travis.yml

@@ -0,0 +1,8 @@
+language: go
+
+install:
+  - go get -d -v .
+
+script:
+  - go build -v ./
+

sdk/sdk-kafkaconnect/README.md

@@ -74,7 +74,7 @@ ctx = context.WithValue(context.Background(), kafkaconnect.ContextOperationServe
 
 ## Documentation for API Endpoints
 
-All URIs are relative to *http://localhost*
+All URIs are relative to */admin/kafkaconnect*
 
 Class | Method | HTTP request | Description
 ------------ | ------------- | ------------- | -------------
@@ -95,14 +95,19 @@ Class | Method | HTTP request | Description
 *DefaultAPI* | [**ListConnectorPluginsCatalog**](docs/DefaultAPI.md#listconnectorpluginscatalog) | **Get** /connector-plugins/catalog | List all connector catalog
 *DefaultAPI* | [**ListConnectors**](docs/DefaultAPI.md#listconnectors) | **Get** /connectors | 
 *DefaultAPI* | [**PauseConnector**](docs/DefaultAPI.md#pauseconnector) | **Put** /connectors/{connector}/pause | 
+*DefaultAPI* | [**PauseConnectorV2**](docs/DefaultAPI.md#pauseconnectorv2) | **Put** /connectors/{connector}:pause | 
 *DefaultAPI* | [**PutConnectorConfig**](docs/DefaultAPI.md#putconnectorconfig) | **Put** /connectors/{connector}/config | 
 *DefaultAPI* | [**ResetConnectorActiveTopics**](docs/DefaultAPI.md#resetconnectoractivetopics) | **Put** /connectors/{connector}/topics/reset | 
+*DefaultAPI* | [**ResetConnectorActiveTopicsV2**](docs/DefaultAPI.md#resetconnectoractivetopicsv2) | **Put** /connectors/{connector}/topics:reset | 
 *DefaultAPI* | [**ResetConnectorOffsets**](docs/DefaultAPI.md#resetconnectoroffsets) | **Delete** /connectors/{connector}/offsets | 
 *DefaultAPI* | [**RestartConnector**](docs/DefaultAPI.md#restartconnector) | **Post** /connectors/{connector}/restart | 
+*DefaultAPI* | [**RestartConnectorV2**](docs/DefaultAPI.md#restartconnectorv2) | **Post** /connectors/{connector}:restart | 
 *DefaultAPI* | [**RestartTask**](docs/DefaultAPI.md#restarttask) | **Post** /connectors/{connector}/tasks/{task}/restart | 
 *DefaultAPI* | [**ResumeConnector**](docs/DefaultAPI.md#resumeconnector) | **Put** /connectors/{connector}/resume | 
+*DefaultAPI* | [**ResumeConnectorV2**](docs/DefaultAPI.md#resumeconnectorv2) | **Put** /connectors/{connector}:resume | 
 *DefaultAPI* | [**ServerInfo**](docs/DefaultAPI.md#serverinfo) | **Get** / | 
 *DefaultAPI* | [**StopConnector**](docs/DefaultAPI.md#stopconnector) | **Put** /connectors/{connector}/stop | 
+*DefaultAPI* | [**StopConnectorV2**](docs/DefaultAPI.md#stopconnectorv2) | **Put** /connectors/{connector}:stop | 
 *DefaultAPI* | [**ValidateConfigs**](docs/DefaultAPI.md#validateconfigs) | **Put** /connector-plugins/{pluginName}/config/validate | Validate the provided configuration against the configuration definition for the specified pluginName
 
 
@@ -114,17 +119,20 @@ Class | Method | HTTP request | Description
  - [ConfigKeyInfo](docs/ConfigKeyInfo.md)
  - [ConfigValueInfo](docs/ConfigValueInfo.md)
  - [ConnectorInfo](docs/ConnectorInfo.md)
+ - [ConnectorOffset](docs/ConnectorOffset.md)
+ - [ConnectorOffsets](docs/ConnectorOffsets.md)
  - [ConnectorState](docs/ConnectorState.md)
  - [ConnectorStateInfo](docs/ConnectorStateInfo.md)
  - [ConnectorTaskId](docs/ConnectorTaskId.md)
  - [CreateConnectorRequest](docs/CreateConnectorRequest.md)
+ - [ErrorMessage](docs/ErrorMessage.md)
  - [FunctionMeshConnectorDefinition](docs/FunctionMeshConnectorDefinition.md)
+ - [Message](docs/Message.md)
  - [PluginInfo](docs/PluginInfo.md)
- - [SNConnectorOffset](docs/SNConnectorOffset.md)
- - [SNConnectorOffsets](docs/SNConnectorOffsets.md)
  - [ServerInfo](docs/ServerInfo.md)
  - [TaskInfo](docs/TaskInfo.md)
  - [TaskState](docs/TaskState.md)
+ - [WorkerStatus](docs/WorkerStatus.md)
 
 
 ## Documentation For Authorization