[Improvement] Fix async drop-event log throttling race in AsyncQueueListener
#10169 · Java · ★ 3.2k · Apache-2.0 · updated 2mo ago
What would you like to be improved? AsyncQueueListener.logDropEventsIfNecessary() uses atomic counters, but its 60-second log-throttling timestamp (lastRecordDropEventTime) is unsynchronized shared state. Under concurrent drops, threads can evaluate the time gate with stale data,…
replies in ~0h10/11 outside PRs mergedhas CONTRIBUTINGsomeone tried before
Cleared 2m ago