As a follow up of comments: https://github.com/swift-server/swift-kafka-client/pull/139#discussion_r1373480287 https://github.com/swift-server/swift-kafka-client/pull/139#discussion_r1377926636 Probably, it worth to request batches high-low watermark to avoid triggering backpressure.