What Debezium server do you use and what version?

3.2.0.Final

How to reproduce the issue using our tutorial deployment?

set heartbeat interval in application.properties

debezium.source.heartbeat.interval.ms=5000

loop in https://github.com/debezium/debezium-server/blob/main/debezium-server-redis/src/main/java/io/debezium/server/redis/RedisStreamChangeConsumer.java#L170 never completes.

Heartbeat message is skipped but not removed from 

clonedBatch

 list. 

see lines 193 and 194.