swift-server / swift-kafka-client

Apache License 2.0
83 stars 23 forks source link

Poll batches according to backpressure #145

Closed blindspotbounty closed 6 months ago

blindspotbounty commented 1 year ago

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.

blindspotbounty commented 6 months ago

I think this one is no more relevant since we are using librdkafka embedded backpressure