Util for kafkajs to buffer messages and send them in batches, inspired by node-rdkafka - View it on GitHub