...
The property “Replication-Factor” will enable to handle failed broker or server.
Code Block | ||
---|---|---|
| ||
kafka/bin/kafka-topics.sh --create \ --zookeeper localhost:2181 \ --replication-factor 3 \ --partitions 3 \ --topic unique-topic-name |
The replication set to 2 or 3 at minimum so that failures or machine maintenance will not interrupt the cluster’s operation.
...
...
If one broker is down, Kafka search for a new following peer to replace the quorum member.