chore(config): make DefaultVersion V2_0_0_0

Also put default SASLHandshake version back to V1 Signed-off-by: Dominic Evans <dominic.evans@uk.ibm.com>
IBM · Aug 7, 2023 · 765bfa3 · 765bfa3
1 parent bb864d7
commit 765bfa3
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git 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
@@ -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{