# Filebeat -\> kafka -\> logstash multiple brokers
**URL:** https://discuss.elastic.co/t/filebeat-kafka-logstash-multiple-brokers/301978
**Category:** Logstash
**Created:** [April 8, 2022, 1:33pm UTC](https://discuss.elastic.co/t/filebeat-kafka-logstash-multiple-brokers/301978 "2022-04-08T13:33:14Z")
**Posts on this page:** 3
**Page:** 1
### Author:  [@alex\_vermex](https://discuss.elastic.co/u/alex_vermex)
#### Post date: [April 8, 2022, 1:33pm UTC](https://discuss.elastic.co/t/filebeat-kafka-logstash-multiple-brokers/301978/1 "2022-04-08T13:33:14Z")
Hi,
I have 3 brokers in one kafka cluster with zookeeper server and i create some topics with **--replication-factor 3 --partitions 3**
I run the zookeeper and the 3 brokers it works fine but when i kill the broker 1 it didn't work it should work with broker 2 or 3 when broker 1 comes back right?
So in this case logstash will wait the broker 1 who works in port 9092 to work there is no solution to work with broker 2 or 3 if broker 1 down ?
filebeat.yml
```auto
output.kafka:
hosts: ["127.0.0.1:9092","127.0.0.1:9093","127.0.0.1:9094"]
topic: '%{[fields.kafka_topic]}'
codec.format:
string: '%{[message]}'
partition.round_robin:
reachable_only: false
required_acks: 1
compression: gzip
max_message_bytes: 1000000000
close_inactive: 50m
```
logstash.conf
```auto
input {
kafka {
bootstrap_servers => "127.0.0.1:9092,127.0.0.1:9093,127.0.0.1:9094"
topics => ["kafka-topic-1","kafka-topic-2","kafka-topic-3","kafka-topic-4"]
decorate_events => true
}
}
```
Is my config correct?
Any help would be sincerely appreciate!
---
### Author:  [@alex\_vermex](https://discuss.elastic.co/u/alex_vermex)
#### Post date: [April 9, 2022, 9:06am UTC](https://discuss.elastic.co/t/filebeat-kafka-logstash-multiple-brokers/301978/2 "2022-04-09T09:06:21Z")
And i created the topics with this command `.\bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 3 --partitions 3 --topic kafka-topic-1 `
because this command gives me an error `.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 3 --partions 3 --topic kafka-topic-1`
```auto
Exception in thread "main" joptsimple.UnrecognizedOptionException: zookeeper is not a recognized option
```
Any help would be sincerely appreciate!
Thanks!
---
### Author:  [@system](https://discuss.elastic.co/u/system)
#### Post date: [May 7, 2022, 9:06am UTC](https://discuss.elastic.co/t/filebeat-kafka-logstash-multiple-brokers/301978/3 "2022-05-07T09:06:33Z")
This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.