search

joekiller / logstash-kafka

Kafka plugin for Logstash
Apache License 2.0
206 stars 63 forks source link

Kafka::Consumer caught exception: Java::KafkaConsumer::ConsumerTimeoutException #59

Open xiaowei1118 opened 7 years ago

xiaowei1118 commented 7 years ago

hi,when I use logstash2.4 to read kafka data ,then Consumer TimeoutException happened,and my zookeeper created the session normally, Can you help me sovle this problem? There is my config file.

input{
    kafka{
        zk_connect=>"172.17.0.1:2181"
        group_id=>"fa"
        topic_id=>"test"
        auto_offset_reset=>"smallest"
        consumer_timeout_ms=>10000
        consumer_threads=> 1
        queue_size=>10
        reset_beginning=>true
        codec=>"plain"
    }
}

output{
  stdout{
  }
}
xiaowei1118 commented 7 years ago

and I find this

2017-04-12 08:49:32,126 [myid:] - INFO  [ProcessThread(sid:0 cport:2181)::PrepRequestProcessor@651] - Got user-level KeeperException when processing sessionid:0x15b60aec8af0023 type:create cxid:0x36 zxid:0x3d7 txntype:-1 reqpath:n/a Error Path:/consumers/console-consumer-56933/offsets/test Error:KeeperErrorCode = NodeExists for /consumers/console-consumer-56933/offsets/test