Как решить ситуацию, когда консюмер не успевает обрабатывать сообщения и копится очередь?