Kafka Consumer Lag Simulator | Codefarm

Consumer Lag Simulator

Understand how consumer lag grows and clears when produce/consume rates differ

Kafka Consumer Lag Simulator

Topic Name

user-events

Partitions

Producer Key Mode

Producer Rate (msg/s)

Consumer Group Size

Rate per Consumer (msg/s)

Lag Explanation

100msg/s

user-events(3 partitions)

50msg/s

Rate Difference: 100 - 50 = 50 msg/s

Lag is GROWING by 50 messages/second

100 (producer) − 50 (consumer) = 50 msg/s → LAG GROWING

Live Visualization

Topic Status:LAG GROWING

0 messages lag

Partition Distribution

Topic Offset

Consumer Offset

Total Lag

Time to Clear

—

Consumer Group (1 consumers, 1 active)

Consumer-1

idle

Elapsed: 0.0s