venice icon indicating copy to clipboard operation
venice copied to clipboard

WIP: Increased Unsubscribe Wait

Open KaiSernLim opened this issue 1 year ago • 0 comments

Summary

  1. Added server.wait.after.unsubscribe.timeout.ms to extend the waitAfterUnsubscribe() timeout, becoming a configurable setting
    1. Increased the default value of this timeout from 10s to 5m
    2. During shutdown / termination scenarios when KafkaConsumerService#unsubscribeAll() is called, the timeout will remain 10s in order to not block shutdown
  2. Added metric wait_after_unsubscribe_latency to track and gather data about how long consumers need to wait after unsubscribing until the next poll() request is called, and it's safe to proceed

How was this PR tested?

GHCI

Does this PR introduce any user-facing changes?

  • [X] No. You can skip the rest of this section.

KaiSernLim avatar Oct 03 '24 21:10 KaiSernLim