Leader election in Kafka - Mini Project: Build & Apply

Leader election

📖 Scenario: You are working with a Kafka cluster where multiple brokers participate in leader election for partitions. Understanding how leader election works helps ensure high availability and fault tolerance in distributed systems.

🎯 Goal: Build a simple Kafka leader election simulation using Python to understand how a leader is chosen from a list of brokers.

📋 What You'll Learn

Create a list of broker IDs

Set a threshold to decide leader eligibility

Use a comprehension to select eligible leaders

Print the chosen leader

💡 Why This Matters

🌍 Real World

Leader election is a key part of distributed systems like Kafka to decide which broker manages a partition.

💼 Career

Understanding leader election helps in roles like DevOps, Site Reliability Engineering, and backend development where managing distributed systems is common.

1

Create the list of brokers

Create a list called brokers with these exact integer values: 101, 102, 103, 104, 105.

Kafka

# Create a list called brokers with the given broker IDs
# Your code here

Need a hint?

Use square brackets to create a list and separate values with commas.

2

Set the leader eligibility threshold

Create a variable called leader_threshold and set it to 103.

Kafka

brokers = [101, 102, 103, 104, 105]
# Create a variable leader_threshold and set it to 103
# Your code here

Need a hint?

Assign the number 103 to the variable leader_threshold.

3

Select eligible leaders using list comprehension

Create a list called eligible_leaders using a list comprehension that includes only brokers from brokers with IDs greater than or equal to leader_threshold.

Kafka

brokers = [101, 102, 103, 104, 105]
leader_threshold = 103
# Create eligible_leaders list with brokers >= leader_threshold using list comprehension
# Your code here

Need a hint?

Use a list comprehension with an if condition to filter brokers.

4

Print the chosen leader

Print the smallest broker ID from eligible_leaders as the chosen leader using print().

Kafka

brokers = [101, 102, 103, 104, 105]
leader_threshold = 103
eligible_leaders = [broker for broker in brokers if broker >= leader_threshold]
# Print the smallest broker ID from eligible_leaders
# Your code here

Need a hint?

Use the min() function to find the smallest ID in the list.