Set read/write/metadata timeouts to the provider configured timeout

Mongey · Feb 29, 2024 · e94ca55 · e94ca55
1 parent b356daa
commit e94ca55
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/kafka/config.go b/kafka/config.go
@@ -50,6 +50,10 @@ func (c *Config) newKafkaConfig() (*sarama.Config, error) {
 	kafkaConfig.Net.Proxy.Enable = true
 	kafkaConfig.Net.Proxy.Dialer = proxy.FromEnvironment()
 
+	kafkaConfig.Net.ReadTimeout = time.Duration(c.Timeout) * time.Second
+	kafkaConfig.Net.WriteTimeout = time.Duration(c.Timeout) * time.Second
+	kafkaConfig.Metadata.Timeout = time.Duration(c.Timeout) * time.Second
+
 	if c.saslEnabled() {
 		switch c.SASLMechanism {
 		case "scram-sha512":