Skip to content
This repository has been archived by the owner on Dec 7, 2020. It is now read-only.

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

Open
xiaowei1118 opened this issue Apr 12, 2017 · 1 comment

Comments

@xiaowei1118
Copy link

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
Copy link
Author

xiaowei1118 commented Apr 12, 2017

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

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant