# Logstash kafka input plugin:can not read data from kafka

**URL:** https://discuss.elastic.co/t/logstash-kafka-input-plugin-can-not-read-data-from-kafka/98164
**Category:** Logstash
**Created:** [August 24, 2017, 6:55am UTC](https://discuss.elastic.co/t/logstash-kafka-input-plugin-can-not-read-data-from-kafka/98164 "2017-08-24T06:55:07Z")
**Posts on this page:** 4
**Page:** 1

<div class="post-metadata">

### Author: ![xiaoxinba](https://avatars.discourse-cdn.com/v4/letter/x/e79b87/32.png) [@xiaoxinba](https://discuss.elastic.co/u/xiaoxinba)
#### Post date: [August 24, 2017, 6:55am UTC](https://discuss.elastic.co/t/logstash-kafka-input-plugin-can-not-read-data-from-kafka/98164/1 "2017-08-24T06:55:08Z")

</div>

Now,my logstash can not consume data from kafka;  
logstash configuration:  
`input { kafka { bootstrap_servers => group_id => } } filter{ XXXX } output{ elasticsearch{XXX} }`

when i see logstash comsuer offset from kafka, i found  
Group Topic Pid Offset logSize Lag Owner  
logstash log-xxx 0 544167 3598995 3054828 none

and the offset can not be changed,

So i add the configuation: enable\_auto\_commit=false ; then logstash can read data?  
why??? maybe zookeeper can not working well????

anyone help???

---

<div class="post-metadata">

### Author: ![inhinyera16](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/inhinyera16/32/61625_2.png) [@inhinyera16](https://discuss.elastic.co/u/inhinyera16)
#### Post date: [August 24, 2017, 9:17am UTC](https://discuss.elastic.co/t/logstash-kafka-input-plugin-can-not-read-data-from-kafka/98164/2 "2017-08-24T09:17:23Z")

</div>

1. Check if kafka broker is running.
2. Make sure you have the ff config in your input  
kafka {  
topics =\> ["mytopic"]  
bootstrap\_servers =\> "host1:port,host2:port"  
}

---

<div class="post-metadata">

### Author: ![xiaoxinba](https://avatars.discourse-cdn.com/v4/letter/x/e79b87/32.png) [@xiaoxinba](https://discuss.elastic.co/u/xiaoxinba)
#### Post date: [August 24, 2017, 12:28pm UTC](https://discuss.elastic.co/t/logstash-kafka-input-plugin-can-not-read-data-from-kafka/98164/3 "2017-08-24T12:28:06Z")

</div>

yes,kafka broker is running; and by kafka console consumer,we can get data;

and i have correct config about logstash

```
input{
   kafka{
        group_id=>
        topics=>
        bootstrap_servers=>
  }
}
```

---

<div class="post-metadata">

### Author: ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)
#### Post date: [September 21, 2017, 12:29pm UTC](https://discuss.elastic.co/t/logstash-kafka-input-plugin-can-not-read-data-from-kafka/98164/4 "2017-09-21T12:29:03Z")

</div>

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.