I can try to decompose your consumer operations into a set of elementary more once and connect them by topics (change topology) of processing. Think also bout involving Kafka Streams, which handle parallelism and durability problems. Backpressure is very often not a good idea, because it requires more logic and leads to intentional performance degradation.