kafka4s
kafka4s copied to clipboard
KAYAK-1398 Use interruptible for send
KAYAK-1398 This is a first pass for low-hanging blocking
fruit.
I've updated this to instead use interruptible(many = false)
, since Producer#send
respects thread interruption:
InterruptException - If the thread is interrupted while blocked
Since this is new and introduces some risk, I'm going to wait till we've determined that ce3 is stable in prod before merging.
A blast from the past
Heh I noticed this today too. You were 2.5 years ahead!