Upgrade Kakfa client version to 2.6.0

Signed-off-by: Sarunas Krisciukaitis <sarunas.krisciukaitis@gmail.com>
ovh · Jan 24, 2022 · bd8fcad · bd8fcad
1 parent 52b6858
commit bd8fcad
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)