Trigger delete records to move the offset relative to the last known offset for each selected partition

A Steadybit extension with various actions and check about Kafka.

Steadybit

Check the partition activity for a given topic

Produce a certain amount of kafka messages for a given duration

Produce records periodically (records per second)

Trigger election for a new leader for a given topic and partition(s), asking for the preferred replica. Warning: in order to force the new election, we change the replica order so that the next in-sync replica is first and the current leader is last.


## Intent

Intentionally deny access to the topic for consumers and during this time where consumption is stopped, delete records.

We can check the logs of the consumers to see how they handle the loss of records and also authorization access issues.

Parameter	Description	Default
X from newest Offset	To move the offset in the past, 0 means to the last known offset (skipping every records from where the consumer was).
Partition to issue delete records requests	One or more partitions to delete the records.

Trigger Delete Records

Trigger Delete Records

Trigger Delete Records

Trigger Delete Records

Introduction

Use Cases

Parameters

Check Kafka consumer's reaction to record loss

Intent

Check Partitions

Produce (# of Records)

Produce (Records / s)

Reduce Message Batch Size

Trigger Partition Leader Election