title: Logstash is not reading from Kafka
body: <p>I am testing a simple pipeline - 
  Filebeat > Fafka > Logstash > File.</p>
  
  <p>Logstash is not reading from Kafka, but I see Kafka has messages when i use this command - </p>
  
  <pre><code>bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic MyTopic --from-beginning
  </code></pre>
  
  <p>My file beat configuration - </p>
  
  <pre><code>filebeat.prospectors:
  - input_type: log
    paths:
      - /root/LogData/input.log
  
  output.kafka:
    hosts: ["10.247.186.14:9092"]
  
    topic: MyTopic 
    partition.round_robin:
      reachable_only: false
  
    required_acks: 1
    compression: none
    max_message_bytes: 1000000
  </code></pre>
  
  <p>My Logstash configuration </p>
  
  <pre><code>input {
          kafka {
                  bootstrap_servers =&gt; "localhost:9092"
                  topics =&gt; ["MyTopic"]
          }
  
  }
  
  output {
  
          file {
                  path =&gt; "/usr/share/logstash/test_out.log"
  
          }
  }
  </code></pre>
  
  <p>My Fafka &amp; Logstash are running on same VM, 
  I am using Logstash docker, I started the docker of Logstash as follows - </p>
  
  <pre><code>sudo docker run -d --name logstash --expose 25826 -p 25826:25826 docker.elastic.co/logstash/logstash:5.4.0 --debug
  </code></pre>
  
  <p>Filebeat running on different VM.</p>
  
  <p>I am creating topic as follows - </p>
  
  <pre><code>bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic MyTopic
  </code></pre>