I read these messages into a concurrent queue, and...
# coroutines
s
I read these messages into a concurrent queue, and another thread (this is handled by the connect framework) will poll this queue and release the memory.
sleep
can avoid putting too many messages in the queue.