Kafka中QueueFullException异常

原文地址：https://cwiki.apache.org/confluence/display/KAFKA/FAQ


Why do I get QueueFullException in my producer when running in async mode?

This typically happens when the producer is trying to send messages quicker than the broker can handle. If the producer can't block, one will have to add enough brokers so that they jointly can handle the load. If the producer can block, one can set queue.enqueueTimeout.ms
in producer config to -1. This way, if the queue is full, the producer will block instead of dropping messages.