Skip to content

Latest commit

 

History

History
26 lines (19 loc) · 1.25 KB

kafka-exercise-partition-leader-election-and-consumer-fail-over.md

File metadata and controls

26 lines (19 loc) · 1.25 KB

Exercise: Partition Leader Election and Consumer Fail-Over

In this exercise you will experiment with partition leader election and consumer fail-over.

Duration: 30 mins

TIP Use bit.ly/kafka-exercise-admin-05 to access this exercise.

Procedure

  1. Create a 3-broker Kafka cluster
  • Use custom broker.id to make sure the ids are yours in kafka-topics later
  • KafkaServer id=59
  • KafkaServer id=66
  • KafkaServer id=47
  1. Create a topic t1 with 1 partition and replication factor of 2
  • ./bin/kafka-topics.sh --create --bootstrap-server :9092 --topic t1 --partitions 1 --replication-factor 2
  • ./bin/kafka-topics.sh --describe --bootstrap-server :9092 --topic t1
  1. Produce and consume a few messages

At this point you should have a topic with replication factor of 2, one producer and one consumer. You made sure that communication between the clients is established (the clients can exchange messages).

  1. Shut down the partition leader
  2. Observe what happens with the clients and whether they can communicate with the cluster and with each other
  3. Use kafka-topics to check out the leader