feat(config): Use a proxy dialer

Mongey · Sep 14, 2023 · 7bc0150 · 7bc0150
1 parent 8f1482f
commit 7bc0150
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/kafka/config.go b/kafka/config.go
@@ -10,6 +10,7 @@ import (
 	"time"
 
 	"github.com/IBM/sarama"
+	"golang.org/x/net/proxy"
 )
 
 type Config struct {
@@ -34,6 +35,9 @@ func (c *Config) newKafkaConfig() (*sarama.Config, error) {
 	kafkaConfig.Metadata.Full = true // the default, but just being clear
 	kafkaConfig.Metadata.AllowAutoTopicCreation = false
 
+	kafkaConfig.Net.Proxy.Enable = true
+	kafkaConfig.Net.Proxy.Dialer = proxy.FromEnvironment()
+
 	if c.saslEnabled() {
 		switch c.SASLMechanism {
 		case "scram-sha512":