bump new API config.Version to V1_0_0_0 to fix SASL handshake (#22)

pceric · Feb 15, 2024 · e4dd910 · e4dd910
1 parent 7b5f9e6
commit e4dd910
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/main.go b/main.go
@@ -93,7 +93,7 @@ func main() {
 		config.ClientID = "kafka-offset-lag-for-prometheus"
 		config.Version = sarama.V0_9_0_0
 		if *enableNewAPI {
-			config.Version = sarama.V0_10_2_0
+			config.Version = sarama.V1_0_0_0
 		}
 		if *saslUser != "" {
 			config.Net.SASL.Enable = true