Logstash with multiple kafka inputs
<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>