title: No such host where i connect to kafka broker on server via port forwarding
body: <p>I have following problem:
  i have running instance of kafka broker on server in k8s. 
  This broker i have port forwarded to localhost kubectl port-forward kafka-broker-0 9104. </p>
  
  <p>I'am sure it works, because I try it from my python app, but if i try example in go from internet</p>
  
  <pre><code>package main
  
  import (
      "fmt"
      "os"
      "os/signal"
  
      kingpin "gopkg.in/alecthomas/kingpin.v2"
  
      "github.com/Shopify/sarama"
  )
  
  var (
      brokerList        = kingpin.Flag("brokerList", "List of brokers to connect").Default("localhost:9104").Strings()
      topic             = kingpin.Flag("topic", "Topic name").Default("important").String()
      partition         = kingpin.Flag("partition", "Partition number").Default("0").String()
      offsetType        = kingpin.Flag("offsetType", "Offset Type (OffsetNewest | OffsetOldest)").Default("-1").Int()
      messageCountStart = kingpin.Flag("messageCountStart", "Message counter start from:").Int()
  )
  
  func main() {
      kingpin.Parse()
      config := sarama.NewConfig()
      config.Consumer.Return.Errors = true
      brokers := *brokerList
      master, err := sarama.NewConsumer(brokers, config)
      if err != nil {
          panic(err)
      }
      defer func() {
          if err := master.Close(); err != nil {
              panic(err)
          }
      }()
      consumer, err := master.ConsumePartition(*topic, 0, sarama.OffsetOldest)
      if err != nil {
          panic(err)
      }
      signals := make(chan os.Signal, 1)
      signal.Notify(signals, os.Interrupt)
      doneCh := make(chan struct{})
      go func() {
          for {
              select {
              case err := &lt;-consumer.Errors():
                  fmt.Println(err)
              case msg := &lt;-consumer.Messages():
                  *messageCountStart++
                  fmt.Println("Received messages", string(msg.Key), string(msg.Value))
              case &lt;-signals:
                  fmt.Println("Interrupt is detected")
                  doneCh &lt;- struct{}{}
              }
          }
      }()
      &lt;-doneCh
      fmt.Println("Processed", *messageCountStart, "messages")
  }
  </code></pre>
  
  <p>i've got error </p>
  
  <pre><code>panic: dial tcp: lookup host.docker.internal: no such host
  
  goroutine 1 [running]:
  main.main()
      /Users/anonymous/go/src/pr1/kafka-consumer.go:37 +0x33b
  exit status 2
  </code></pre>
  
  <p>pls, where can be a problem?</p>