一台机器启动多个logstash问题

[attach]805[/attach]

input{

        kafka{

                codec =>plain{charset => "UTF-8"}

                zk_connect => "*.*.*.*:2181,*.*.*.*:2181,*.*.*.*:2181"

               #topic_id => "minos2_useraction"

                topic_id => "minos2_alipay"

                group_id => "logstash"

                reset_beginning => true

                decorate_events => true

                rebalance_backoff_ms => 5000

                rebalance_max_retries => 10

                #consumer_threads => 4

                consumer_restart_sleep_ms => 2000

                #consumer_id => security2

                add_field => {

                                "messageTopic" => "minos2_useraction"

                        }

        }

}



stdout {

            codec => dots

        }

        if([messageTopic] == "minos2_useraction"){

                 elasticsearch{

        #       codec=>rubydebug

        #       codec => plain{charset => "UTF-8"}

                hosts => ["10.27.232.156:9200"]

                index => "minos3log%{date}"

                #document_type => "minos2"

                document_type => "%{eventId}"

                flush_size => 1000

                idle_flush_time => 1

                }

        }