diff --git a/lib/kafkalib/connection.go b/lib/kafkalib/connection.go
index cc4613114..386207d28 100644
--- a/lib/kafkalib/connection.go
+++ b/lib/kafkalib/connection.go
@@ -65,7 +65,6 @@ func (c Connection) Dialer(ctx context.Context) (*kafka.Dialer, error) {
 		if !c.disableTLS {
 			dialer.TLS = &tls.Config{}
 		}
-
 	case AwsMskIam:
 		_awsCfg, err := awsCfg.LoadDefaultConfig(ctx)
 		if err != nil {