kop
kop copied to clipboard
[FEATURE] Trigger pending fetches when producing messages
When the Kafka client issues a Fetch and sets a maxWait time we are already scheduling a DelayedFetch, but there is no way to trigger that Fetch and it is deemed to wait for the fully timeout. This adds latency spikes on the Kafka Consumer.