Handling Fault Tolerance

Fault Tolerance and Robustness in Kafka.

  1. Run the Kafka producer
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test-topic-replicated
producing messages.

2. Run the Kafka Consumer.

.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-topic-replicated 
consuming messages

Let's bring one of the brokers down.

→ now check on the consumer console you will see the warning.

Server down? but still, a consumer is receiving the messages.

  • But do not worry, even the server-2 is down, you are still able to send and receive the message and the client still doesn’t have an idea about it, right?

Summary: This is the fault-tolerant behavior. So Kafka takes error handling and in a client perspective view, you don’t have to worry much about it.

I am Full Stack Java Developer @ Tata Strive | Get blogs and tutorials related to the (React | Kafka | DevOps) | Follow me on LinkedIn https://www.linkedin.com

Love podcasts or audiobooks? Learn on the go with our new app.

Recommended from Medium

How to Plan and Create Content for Beginners?

How to Plan and Create Content for Beginners to Learn Programming? — Vijay Thapa

It’s Test O’Clock!

Deployment of Ansible AWX on OpenShift Origin

Superdense Coding (SDC)

AWS Lambda Power Tuning with AWS Step Functions

NFTY Spotlight: Meet Kevin, CTO

The Benefits of Using the Cloud :

“RU77” game. Developer diary #7

Get the Medium app

A button that says 'Download on the App Store', and if clicked it will lead you to the iOS App store
A button that says 'Get it on, Google Play', and if clicked it will lead you to the Google Play store
Sagar Kudu

Sagar Kudu

I am Full Stack Java Developer @ Tata Strive | Get blogs and tutorials related to the (React | Kafka | DevOps) | Follow me on LinkedIn https://www.linkedin.com

More from Medium

Kafka for dummies and with practical failure experiments

How to use Schema Registry Plugin with HTTPS enabled

Kafka Quickstart

Kafka Bidirectional Client/Broker Compatibility