From 8b3904a9c5a83c7ecd98d2fb73f283a69b124eab Mon Sep 17 00:00:00 2001 From: Felix Geller Date: Sat, 20 Nov 2021 01:37:21 +0100 Subject: [PATCH] defaults to kafka v3 --- common.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/common.go b/common.go index e143a0c..4e011b7 100644 --- 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"))