When sarama input buffer is full, whole process (consuming & producing)
is blocked. This PR fix that problem. It prevents blocking on sarama
partition dispatcher. Drop message when buffer is full.
Not only that adding a new buffer layer on nozzle side (subInput).
So that we don't lose logs.
When sarama input buffer is full, whole process (consuming & producing) is blocked. This PR fix that problem. It prevents blocking on sarama partition dispatcher. Drop message when buffer is full.
Not only that adding a new buffer layer on nozzle side (subInput). So that we don't lose logs.