venice
venice copied to clipboard
WIP: Increased Unsubscribe Wait
Summary
- Added
server.wait.after.unsubscribe.timeout.msto extend thewaitAfterUnsubscribe()timeout, becoming a configurable setting- Increased the default value of this timeout from
10sto5m - During shutdown / termination scenarios when
KafkaConsumerService#unsubscribeAll()is called, the timeout will remain10sin order to not block shutdown
- Increased the default value of this timeout from
- Added metric
wait_after_unsubscribe_latencyto track and gather data about how long consumers need to wait after unsubscribing until the nextpoll()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.