From 765bfa3ae935e3a8ec36b8776ee5d3308b40f28a Mon Sep 17 00:00:00 2001 From: Dominic Evans Date: Mon, 7 Aug 2023 18:39:03 +0100 Subject: [PATCH] chore(config): make DefaultVersion V2_0_0_0 Also put default SASLHandshake version back to V1 Signed-off-by: Dominic Evans --- config.go | 3 +-- utils.go | 2 +- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/config.go b/config.go index 4876d8fbf..990de93a2 100644 --- a/config.go +++ b/config.go @@ -281,7 +281,6 @@ type Config struct { // Consumer is the namespace for configuration related to consuming messages, // used by the Consumer. Consumer struct { - // Group is the namespace for configuring consumer group. Group struct { Session struct { @@ -514,7 +513,7 @@ func NewConfig() *Config { c.Net.ReadTimeout = 30 * time.Second c.Net.WriteTimeout = 30 * time.Second c.Net.SASL.Handshake = true - c.Net.SASL.Version = SASLHandshakeV0 + c.Net.SASL.Version = SASLHandshakeV1 c.Metadata.Retry.Max = 3 c.Metadata.Retry.Backoff = 250 * time.Millisecond diff --git a/utils.go b/utils.go index 63b647f5c..63ac8984b 100644 --- a/utils.go +++ b/utils.go @@ -261,7 +261,7 @@ var ( } MinVersion = V0_8_2_0 MaxVersion = V3_5_1_0 - DefaultVersion = V1_0_0_0 + DefaultVersion = V2_0_0_0 // reduced set of protocol versions to matrix test fvtRangeVersions = []KafkaVersion{