Produce (Records / S)
Attack
New
Produce records periodically (records per second).
Produce (Records / S)
Produce records periodically (records per second).Attack
Produce (Records / S)
Attack
New
Produce records periodically (records per second).
Produce (Records / S)
Produce records periodically (records per second).Attack
Go back to list
Validate consumer's behavior when new leader is elected
Verify that your application handles a change of the leader properly.
Motivation
By testing your system's resilience to Kafka leader changes in a partition, you can identify potential weaknesses and take appropriate measures to improve its performance.
Structure
To conduct this experiment, we will ensure that all Kafka topics and producers are ready and that the consumer receives and processes messages correctly. We will then elect a new leader for one partition in Kafka and expect the system to work fine.
Message Queue
Kafka
Recoverability
Kafka consumers
Kafka topics