Issue 10: EOF error when sending messages to Confluent Cloud (#11)

* issue-10: EOF error when sending messages to Confluent Cloud
mostafa · Jun 28, 2021 · 45ce492 · 45ce492
1 parent c35da2d
commit 45ce492
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/auth.go b/auth.go
@@ -1,6 +1,7 @@
 package kafka
 
 import (
+	"crypto/tls"
 	"encoding/json"
 	"time"
 
@@ -35,6 +36,7 @@ func getDialer(creds *Credentials) (dialer *kafkago.Dialer) {
 	dialer = &kafkago.Dialer{
 		Timeout:   10 * time.Second,
 		DualStack: true,
+		TLS: &tls.Config{},
 	}
 
 	if creds.Algorithm == Plain {