Skip to content

Commit

Permalink
fix and change name
Browse files Browse the repository at this point in the history
  • Loading branch information
lala7573 committed Sep 23, 2020
1 parent 255babd commit ad52547
Show file tree
Hide file tree
Showing 6 changed files with 7 additions and 9 deletions.
6 changes: 3 additions & 3 deletions Makefile
Original file line number Diff line number Diff line change
Expand Up @@ -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 .
2 changes: 1 addition & 1 deletion cmdConnectorDelete.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
}
Expand Down
8 changes: 3 additions & 5 deletions cmdConnectorValidate.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@ import (
"os"
"log"
"bytes"
"strings"
"net/http"
"io/ioutil"
"encoding/json"
Expand All @@ -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)
Expand All @@ -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)
}
Expand Down
Binary file modified kafka-connect-cli
Binary file not shown.
Binary file renamed kafka-connect-cli-mac → kafka-connect-cli.darwin
Binary file not shown.
Binary file renamed kafka-connect-cli-linux → kafka-connect-cli.linux
Binary file not shown.

0 comments on commit ad52547

Please sign in to comment.