title: Logstash with multiple kafka inputs
body: <p>I am trying to filter kafka events from multiple topics, but once all events from one topic has been filtered logstash is not able to fetch events from the other kafka topic. I am using topics with 3 partitions and 2 replications Here is my logstash config file</p>
  
  <pre><code>input {
      kafka{              
          auto_offset_reset =&gt; "smallest"
          consumer_id =&gt; "logstashConsumer1"          
          topic_id =&gt; "unprocessed_log1"
          zk_connect=&gt;"192.42.79.67:2181,192.41.85.48:2181,192.10.13.14:2181"
          type =&gt; "kafka_type_1"
  }
  kafka{              
      auto_offset_reset =&gt; "smallest"
      consumer_id =&gt; "logstashConsumer1"          
      topic_id =&gt; "unprocessed_log2"
      zk_connect =&gt; "192.42.79.67:2181,192.41.85.48:2181,192.10.13.14:2181"
      type =&gt; "kafka_type_2"
  }
  }
  filter{
      if [type] == "kafka_type_1"{
      csv { 
          separator=&gt;" "
          source =&gt; "data"        
      }   
  }
  if [type] == "kafka_type_2"{    
      csv { 
          separator =&gt; " "        
          source =&gt; "data"
      }
  }
  }
  output{
      stdout{ codec=&gt;rubydebug{metadata =&gt; true }}
  }
  </code></pre>