Add tls support

agapoff · agapoff · commit 296e201cbae3 · 2019-08-15T12:10:34.000+03:00
diff --git a/kafka-ops.go b/kafka-ops.go
@@ -12,6 +12,7 @@ import (
     "gopkg.in/yaml.v2"
     "encoding/json"
     "errors"
+    "crypto/tls"
 )
 
 var (
@@ -148,6 +149,13 @@ func main() {
             os.Exit(1)
         }
     }
+    if strings.HasSuffix(protocol, "_ssl") {
+        config.Net.TLS.Enable = true
+        tlsConfig := tls.Config{
+            InsecureSkipVerify: true,
+        }
+        config.Net.TLS.Config = &tlsConfig
+    }
 
     admin, err := sarama.NewClusterAdmin(brokerAddrs, config)
     if err != nil {

Original file line number	Diff line number	Diff line change
`@@ -12,6 +12,7 @@ import (`
`12`	`12`	`"gopkg.in/yaml.v2"`
`13`	`13`	`"encoding/json"`
`14`	`14`	`"errors"`
	`15`	`+ "crypto/tls"`
`15`	`16`	`)`
`16`	`17`
`17`	`18`	`var (`
`@@ -148,6 +149,13 @@ func main() {`
`148`	`149`	`os.Exit(1)`
`149`	`150`	`}`
`150`	`151`	`}`
	`152`	`+ if strings.HasSuffix(protocol, "_ssl") {`
	`153`	`+ config.Net.TLS.Enable = true`
	`154`	`+ tlsConfig := tls.Config{`
	`155`	`+ InsecureSkipVerify: true,`
	`156`	`+ }`
	`157`	`+ config.Net.TLS.Config = &tlsConfig`
	`158`	`+ }`
`151`	`159`
`152`	`160`	`admin, err := sarama.NewClusterAdmin(brokerAddrs, config)`
`153`	`161`	`if err != nil {`