diff --git a/Makefile b/Makefile index 6000b23..3032c9d 100644 --- a/Makefile +++ b/Makefile @@ -6,8 +6,8 @@ build: .PHONY: linux linux: - env GOOS=linux GOARCH=amd64 go build -o kafka-connect-cli-linux . + env GOOS=linux GOARCH=amd64 go build -o kafka-connect-cli.linux . -.PHONY: mac +.PHONY: darwin mac: - env GOOS=darwin GOARCH=amd64 go build -o kafka-connect-cli-mac . + env GOOS=darwin GOARCH=amd64 go build -o kafka-connect-cli.darwin . diff --git a/cmdConnectorDelete.go b/cmdConnectorDelete.go index 51f6fe8..8f6d849 100644 --- a/cmdConnectorDelete.go +++ b/cmdConnectorDelete.go @@ -23,7 +23,7 @@ var cmdConnectorDelete = &cobra.Command{ log.Fatal(err) } if resp.StatusCode == 204 { - fmt.Printf("ok") + fmt.Printf("deleted") } else { fmt.Printf("%d", resp.StatusCode) } diff --git a/cmdConnectorValidate.go b/cmdConnectorValidate.go index e20b150..59590b9 100644 --- a/cmdConnectorValidate.go +++ b/cmdConnectorValidate.go @@ -4,7 +4,6 @@ import ( "os" "log" "bytes" - "strings" "net/http" "io/ioutil" "encoding/json" @@ -24,15 +23,14 @@ var cmdConnectorValidate = &cobra.Command{ config.Config["name"] = name jsonBytes, _ := json.Marshal(&config.Config) className := config.Config["connector.class"] - classNameSplit := strings.Split(className, ".") - classNameOnly := classNameSplit[len(classNameSplit)-1] - url := GetKafkaConnectUrl("connector-plugins", classNameOnly, "config/validate") + url := GetKafkaConnectUrl("connector-plugins", className, "config/validate") req, err := http.NewRequest("PUT", url, bytes.NewBuffer(jsonBytes)) if err != nil { log.Fatal(err) } req.Header.Add("Content-Type", "application/json") req.Header.Add("Accept", "application/json") + resp, err := httpClient.Do(req) if err != nil { log.Fatal(err) @@ -50,7 +48,7 @@ var cmdConnectorValidate = &cobra.Command{ for _, config:= range response.Configs { if len(config.Value.Errors) > 0 { - enc := json.NewEncoder(os.Stdout) + enc := json.NewEncoder(os.Stderr) enc.SetIndent("", " ") enc.Encode(config.Value) } diff --git a/kafka-connect-cli b/kafka-connect-cli index f97d2fb..28f488a 100755 Binary files a/kafka-connect-cli and b/kafka-connect-cli differ diff --git a/kafka-connect-cli-mac b/kafka-connect-cli.darwin similarity index 93% rename from kafka-connect-cli-mac rename to kafka-connect-cli.darwin index f97d2fb..2465828 100755 Binary files a/kafka-connect-cli-mac and b/kafka-connect-cli.darwin differ diff --git a/kafka-connect-cli-linux b/kafka-connect-cli.linux similarity index 85% rename from kafka-connect-cli-linux rename to kafka-connect-cli.linux index 3d303ab..08c33b1 100755 Binary files a/kafka-connect-cli-linux and b/kafka-connect-cli.linux differ