Thanks Aman!

1. We had dataloss, As our consumers are not confirming to exactly-once /at-least once semantics. Our Preference is higher throughput for our case (analytical use case) rather than achieving exactly-once /at-least once semantics. Achieving exactly-once /at-least once will reduce our throughput.

2. Handling backpressure using the features of Project Reactor