[Feature] Should I design a more complicated flow-control mechanism?

[moooofly]

Now

• When overflow happens, simply discard the more recently arrived kafka messages.
• queue-size is a global setting for all kinds of services corresponding to different grpc connections.

Maybe

• Should discard kafka messages by other modes?
• Should a precise control over each grpc connection be needed?