filebeat-output-kafka报错

可以检查：
-- 'describe'你的topic，看是不是有partition没有leader
-- 如果所有partition都正常，下一步排除通信问题，从客户端到broker的通信时间如果太长也有可能会造成类似的错误。比如你的bootstrap server写的是kfk1，log里显示的是szd-xxxx，应该尽量使用broker的FQDN

--describ topic 

/bin/kafka-topics.sh --zookeeper zk-host:2181 --describe --topic tpc77

18/03/01 16:59:34 INFO zkclient.ZkClient: zookeeper state changed (SyncConnected)

Topic:citymain77        PartitionCount:1        ReplicationFactor:1     Configs:

        Topic: tpc77       Partition: 0    Leader: 233     Replicas: 233   Isr: 233

18/03/01 16:59:34 INFO zkclient.ZkEventThread: Terminate ZkClient event thread.

18/03/01 16:59:34 INFO zookeeper.ZooKeeper: Session: 0x161daa6c9640d29 closed

18/03/01 16:59:34 INFO zookeeper.ClientCnxn: EventThread shut down for session: 0x161daa6c9640d29

--logstash配置.conf

input{

        kafka{

                bootstrap_servers => ["10.25.80.146:9092,10.25.80.129:9092"]

                auto_offset_reset => "latest"

                decorate_events => true

                topics => ["citymain77"]

                type => "citymain77"

      }

}

output {

        if [type] == "citymain77" {

                elasticsearch {

                        hosts => ["10.20.112.229:9200","10.20.112.231:9200"]

                        manage_template => false

                        index => "cty77-%{+YYYY.MM.dd}"

                        document_type => "log"

                }

        }



        if [type] == "citymain231" {

                elasticsearch {

                        hosts => ["10.20.112.229:9200","10.20.112.231:9200"]

                        manage_template => false

                        index => "cty231-%{+YYYY.MM.dd}"

                        document_type => "log"

                }

        }

}

 
--logsatsh日志

[root@SZB-L0052000 conf.d]# cat /var/log/logstash/logstash-plain.log

[2018-03-01T17:55:33,937][ERROR][logstash.inputs.kafka    ] Invalid setting for kafka input plugin:



  input {

    kafka {

      # This setting must be a string

      # Expected string, got ["10.25.80.146:9092", "10.25.80.129:9092"]

      bootstrap_servers => ["10.25.80.146:9092", "10.25.80.129:9092"]

      ...

    }

  }

[2018-03-01T17:55:33,958][ERROR][logstash.agent           ] Cannot create pipeline {:reason=>"Something is wrong with your configuration."}

[root@SZB-L0052000 conf.d]#

想请教一些问题，能加个qq吗