defaults to kafka v3

fgeller · Nov 20, 2021 · 8b3904a · 8b3904a
1 parent 165425d
commit 8b3904a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/common.go b/common.go
@@ -52,7 +52,7 @@ func kafkaVersion(s string) sarama.KafkaVersion {
 	}
 
 	if s == "" {
-		return sarama.V2_0_0_0
+		return sarama.V3_0_0_0
 	}
 
 	v, err := sarama.ParseKafkaVersion(strings.TrimPrefix(s, "v"))