Revert "feat(config): Use a proxy dialer"

This reverts commit 7bc0150.
Mongey · Sep 14, 2023 · 5629626 · 5629626
1 parent 7bc0150
commit 5629626
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/kafka/config.go b/kafka/config.go
@@ -10,7 +10,6 @@ import (
 	"time"
 
 	"github.com/IBM/sarama"
-	"golang.org/x/net/proxy"
 )
 
 type Config struct {
@@ -35,9 +34,6 @@ 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":