Expand description
Backpressure controller for Kafka source consumption.
KafkaBackpressureController monitors downstream channel utilization
and signals when the consumer should pause or resume partition
consumption to prevent unbounded memory growth.
Structsยง
- Kafka
Backpressure Controller - Controls consumption rate based on downstream channel fill level.