# Enable to connect Logstash to Kafka

**URL:** https://discuss.elastic.co/t/enable-to-connect-logstash-to-kafka/157563
**Category:** Logstash
**Created:** [November 20, 2018, 2:15pm UTC](https://discuss.elastic.co/t/enable-to-connect-logstash-to-kafka/157563 "2018-11-20T14:15:48Z")
**Posts on this page:** 4
**Page:** 1

<div class="post-metadata">

### Author: ![Youssef\_El](https://avatars.discourse-cdn.com/v4/letter/y/bbe5ce/32.png) [@Youssef\_El](https://discuss.elastic.co/u/Youssef_El)
#### Post date: [November 20, 2018, 2:15pm UTC](https://discuss.elastic.co/t/enable-to-connect-logstash-to-kafka/157563/1 "2018-11-20T14:15:48Z")

</div>

Hello,

I'm trying to connect Kafka to logastash by making kafka input in logstash config file ,but i'm confused with kafka bootstrap\_servers who is hosted in hortonworks platform .

In ambari UI is mentioned that kafka listen on port 6667 but in Elastic documentation is mentioned port number 9092.

Thanks.

---

<div class="post-metadata">

### Author: ![duccanh0022](https://avatars.discourse-cdn.com/v4/letter/d/9fc348/32.png) [@duccanh0022](https://discuss.elastic.co/u/duccanh0022)
#### Post date: [November 21, 2018, 3:32am UTC](https://discuss.elastic.co/t/enable-to-connect-logstash-to-kafka/157563/2 "2018-11-21T03:32:17Z")

</div>

Hello, this is my config  
input {  
kafka {  
bootstrap\_servers =\> ["IP\_ADDRESS\_XXXXX:9092"]  
topics =\> ["topic1"]  
}  
}

---

<div class="post-metadata">

### Author: ![Youssef\_El](https://avatars.discourse-cdn.com/v4/letter/y/bbe5ce/32.png) [@Youssef\_El](https://discuss.elastic.co/u/Youssef_El)
#### Post date: [November 21, 2018, 3:34pm UTC](https://discuss.elastic.co/t/enable-to-connect-logstash-to-kafka/157563/3 "2018-11-21T15:34:21Z")

</div>

Hi,  
This is what i got in the error message with 9092 and 6667 ports .

[2018-11-21T15:27:22,972][WARN][org.apache.kafka.clients.NetworkClient] [Consumer clientId=logstash-0, groupId=logstash] Connection to node -1 could not be established. Broker may not be available.

---

<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: [December 19, 2018, 3:34pm UTC](https://discuss.elastic.co/t/enable-to-connect-logstash-to-kafka/157563/4 "2018-12-19T15:34:24Z")

</div>

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