From 1a5a69f2846cb9a55c8109549f3ecf488b5fb100 Mon Sep 17 00:00:00 2001 From: Sarunas Krisciukaitis Date: Tue, 30 Nov 2021 13:21:26 +0000 Subject: [PATCH] Upgrade Kakfa client version to 2.6.0 Signed-off-by: Sarunas Krisciukaitis --- executors/kafka/kafka.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/executors/kafka/kafka.go b/executors/kafka/kafka.go index adce9c15..228d815e 100644 --- a/executors/kafka/kafka.go +++ b/executors/kafka/kafka.go @@ -336,7 +336,7 @@ func (e Executor) getKafkaConfig() (*sarama.Config, error) { config.Net.SASL.Password = e.Password config.Consumer.Return.Errors = true config.Net.DialTimeout = defaultDialTimeout - config.Version = sarama.V0_10_2_0 + config.Version = sarama.V2_6_0_0 if e.KafkaVersion != "" { kafkaVersion, err := sarama.ParseKafkaVersion(e.KafkaVersion)