From 45ce4923090ecdf860d87b43fe59ff64781bf7e2 Mon Sep 17 00:00:00 2001
From: Florian McKee <84742327+fmck3516@users.noreply.github.com>
Date: Mon, 28 Jun 2021 12:53:33 -0500
Subject: [PATCH] Issue 10: EOF error when sending messages to Confluent Cloud
 (#11)

* issue-10: EOF error when sending messages to Confluent Cloud
---
 auth.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/auth.go b/auth.go
index 8a94a4d..f8ab093 100644
--- 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 {