# Logstash-kafka plugin

**URL:** <https://discuss.elastic.co/t/logstash-kafka-plugin/29539>\
**Category:** Logstash\
**Created:** [September 18, 2015, 4:48am UTC](https://discuss.elastic.co/t/logstash-kafka-plugin/29539 "2015-09-18T04:48:28Z")\
**Posts on this page:** 4\
**Page:** 1

<div class="post-metadata">

**Author:** ![ishantt](https://avatars.discourse-cdn.com/v4/letter/i/7993a0/32.png) [@ishantt](https://discuss.elastic.co/u/ishantt)\
**Post date:** [September 18, 2015, 4:48am UTC](https://discuss.elastic.co/t/logstash-kafka-plugin/29539/1 "2015-09-18T04:48:28Z")

</div>

Greetings Everyone,  
I am a very raw user of logstash and in much a phase of learning it, however I am facing a very curious case in logstash-kafka setup. when I try to send the traffic from logstash to kafka, and if kafka isn't available the logstash just gets crashed and doesn't even try to resend the traffic. I want a case where logstash should give few tries to send the traffic to kafka, and even if it doesn't find kafka at all, it should dump the data somewhere in blackhole until it gets the kafka back instead of getting crashed. is it possible to achieve this with logstash? thank you guys,  
hope you see you reply soon.

---

<div class="post-metadata">

**Author:** ![Joe\_Lawson](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/joe_lawson/32/3390_2.png) [@Joe\_Lawson](https://discuss.elastic.co/u/Joe_Lawson)\
**Post date:** [September 18, 2015, 2:19pm UTC](https://discuss.elastic.co/t/logstash-kafka-plugin/29539/2 "2015-09-18T14:19:42Z")

</div>

Could you share your config? Generally Kafka and logstash should block, ie  
not send messages, if it is unable to communicate with the broker. There  
are a number of settings that can affect how it reacts to errors. Did you  
get any errors?

---

<div class="post-metadata">

**Author:** ![ishantt](https://avatars.discourse-cdn.com/v4/letter/i/7993a0/32.png) [@ishantt](https://discuss.elastic.co/u/ishantt)\
**Post date:** [September 18, 2015, 3:07pm UTC](https://discuss.elastic.co/t/logstash-kafka-plugin/29539/3 "2015-09-18T15:07:14Z")

</div>

input {  
udp {  
port =\> 9995  
codec =\> netflow  
}  
}

output {  
kafka {  
codec =\> json  
broker\_list =\> "node5:9092"  
topic\_id =\> netflow  
}

# stdout { codec =\> rubydebug }

# file{

# codec =\> rubydebug

# path =\> "/home/vagrant/netflow-%{+YYYY-MM-dd-HH}.json"

# }

}

---

<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:** [July 6, 2017, 5:28am UTC](https://discuss.elastic.co/t/logstash-kafka-plugin/29539/4 "2017-07-06T05:28:42Z")

</div>