# Logstash Kafka plugin error

**URL:** <https://discuss.elastic.co/t/logstash-kafka-plugin-error/103599>\
**Category:** Logstash\
**Created:** [October 11, 2017, 6:37pm UTC](https://discuss.elastic.co/t/logstash-kafka-plugin-error/103599 "2017-10-11T18:37:44Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![ashvita](https://avatars.discourse-cdn.com/v4/letter/a/ee59a6/32.png) [@ashvita](https://discuss.elastic.co/u/ashvita)\
**Post date:** [October 11, 2017, 6:37pm UTC](https://discuss.elastic.co/t/logstash-kafka-plugin-error/103599/1 "2017-10-11T18:37:44Z")

</div>

Hi,

I have configured Logstash to receive from 2 Kafka topics using 2 diff conf files but it is only receiving from 1 topic. I can see messages coming on console consumer but logstash is unable to fetch it.  
I am unable to understand what is the issue.  
Below is the debug message that I receive continuously -

[2017-10-11T11:42:01,155][DEBUG][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Sending Heartbeat request for group logstash to coordinator 10.10 0.208.97:9092 (id: 2147483647 rack: null)  
[2017-10-11T11:42:01,156][DEBUG][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Received successful Heartbeat response for group logstash  
[2017-10-11T11:42:03,971][DEBUG][org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] Sending asynchronous auto-commit of offsets {} for group logstash  
[2017-10-11T11:42:04,069][DEBUG][org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] Completed auto-commit of offsets {} for group logstash  
[2017-10-11T11:42:04,169][DEBUG][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Sending Heartbeat request for group logstash to coordinator 10.10 0.208.97:9092 (id: 2147483647 rack: null)  
[2017-10-11T11:42:04,170][DEBUG][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Received successful Heartbeat response for group logstash  
[2017-10-11T11:42:05,896][DEBUG][logstash.pipeline] Pushing flush onto pipeline {:pipeline\_id=\>"main", :thread=\>"#\<Thread:0x4a226753@/home/newELK/ logstash-6.0.0-rc1/logstash-core/lib/logstash/pipeline.rb:290 sleep\>"}  
[2017-10-11T11:42:07,184][DEBUG][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Sending Heartbeat request for group logstash to coordinator 10.10 0.208.97:9092 (id: 2147483647 rack: null)  
[2017-10-11T11:42:07,185][DEBUG][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Received successful Heartbeat response for group logstash  
[2017-10-11T11:42:08,971][DEBUG][org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] Sending asynchronous auto-commit of offsets {} for group logstash  
[2017-10-11T11:42:08,992][DEBUG][org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] Completed auto-commit of offsets {} for group logstash  
[2017-10-11T11:42:10,196][DEBUG][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Sending Heartbeat request for group logstash to coordinator 10.10 0.208.97:9092 (id: 2147483647 rack: null)  
[2017-10-11T11:42:10,196][DEBUG][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Received successful Heartbeat response for group logstash  
[2017-10-11T11:42:10,897][DEBUG][logstash.pipeline] Pushing flush onto pipeline {:pipeline\_id=\>"main", :thread=\>"#\<Thread:0x4a226753@/home/newELK/ logstash-6.0.0-rc1/logstash-core/lib/logstash/pipeline.rb:290 sleep\>"}

---

<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:** [November 8, 2017, 6:38pm UTC](https://discuss.elastic.co/t/logstash-kafka-plugin-error/103599/2 "2017-11-08T18:38:01Z")

</div>

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