# Logstash needs restarting ,once kafka is down and live back again

**URL:** <https://discuss.elastic.co/t/logstash-needs-restarting-once-kafka-is-down-and-live-back-again/120888>\
**Category:** Logstash\
**Created:** [February 21, 2018, 4:05pm UTC](https://discuss.elastic.co/t/logstash-needs-restarting-once-kafka-is-down-and-live-back-again/120888 "2018-02-21T16:05:34Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![Pratheek](https://avatars.discourse-cdn.com/v4/letter/p/a698b9/32.png) [@Pratheek](https://discuss.elastic.co/u/Pratheek)\
**Post date:** [February 21, 2018, 4:05pm UTC](https://discuss.elastic.co/t/logstash-needs-restarting-once-kafka-is-down-and-live-back-again/120888/1 "2018-02-21T16:05:34Z")

</div>

Currently we are facing some issues with logstash .When kafka is down and back live after sometime,logstash is not resuming to get data from the kafka topic ,its still throwing some errors and resumes loading data only when logstash instance is restarted.

Is this normal? ,or am missing anything in the config

input {  
kafka {  
bootstrap\_servers =\> "xxxxxx"  
topics =\> "abc"  
group\_id =\> "sample"  
consumer\_threads =\> 4  
key\_deserializer\_class =\> "org.apache.kafka.common.serialization.ByteArrayDeserializer"  
value\_deserializer\_class =\> "org.apache.kafka.common.serialization.ByteArrayDeserializer"  
codec =\> avro {  
schema\_uri =\> "xyz.avsc"  
tag\_on\_failure =\> true  
}  
}  
}

---

<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:** [March 21, 2018, 4:06pm UTC](https://discuss.elastic.co/t/logstash-needs-restarting-once-kafka-is-down-and-live-back-again/120888/2 "2018-03-21T16:06:00Z")

</div>

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