I wrote a kafka connect, each thread consume a top...

# coroutines

[sailxjx]

I wrote a kafka connect, each thread consume a topic from kafka. There were many topics in kafka, so I need to open many threads. When the incoming messages is greater than my buffer, I use sleep to avoid OOM.