Users have reported that in some cases you don't want kotlin-kafka to automatically pause the partitions in case the downstream cannot process the events fast enough but rather you want it to blow up. For example in cases where a slow processor is considered a bug, and you prefer it crashing the server or stream. For this reason this PR implements a strategy that allows customising this.
Users have reported that in some cases you don't want
kotlin-kafkato automatically pause the partitions in case the downstream cannot process the events fast enough but rather you want it to blow up. For example in cases where a slow processor is considered a bug, and you prefer it crashing the server or stream. For this reason this PR implements a strategy that allows customising this.