support buffer input

Author: opiepj

src/index.d.ts

@@ -226,6 +226,7 @@ export class Producer extends Client {
   constructor(conf?: ProducerConfig, topicConfig?: TopicConfig);
 
   public publish(message: string, topic?: string, partition?: number, key?: string, opaque?: string): Promise<DeliveryReport>;
+  public publishBuffer(messageBuffer: Buffer, topic?: string, partition?: number, key?: string, opaque?: string): Promise<DeliveryReport>;
 
   public report(): Observable<DeliveryReport>;
 

src/producer.js

@@ -65,14 +65,29 @@ class Producer extends KafkaClient {
    * @TODO will delivery report be synchronized with produce?
    */
   publish(message, topic = this._config.topics[0], partition = -1, key = null, opaque = null) {
+    // eslint-disable-next-line new-cap
+    return this.publishBuffer(new Buffer.from(message), topic, partition, key, opaque);
+  }
+
+  /**
+   * Publish a message
+   * @param {Buffer} messageBuffer - message buffer to send
+   * @param {String} [topic=this._config.topics[0]] - topic to send to
+   * @param {number} [partition=-1] - optionally  specify a partition for the message, this defaults to -1 - which will
+   *  use librdkafka's default partitioner (consistent random for keyed messages, random for unkeyed messages)
+   * @param {String} [key=null] - keyed message (optional)
+   * @param {String} [opaque=null] - opaque token which gets passed along to your delivery reports
+   * @return {Promise<DeliveryReport>}
+   * @TODO will delivery report be synchronized with produce?
+   */
+  publishBuffer(messageBuffer, topic = this._config.topics[0], partition = -1, key = null, opaque = null) {
     return new Promise((resolve, reject) => {
 
       try {
         this.kafkaProducer.produce(
           topic,
           partition,
-          // eslint-disable-next-line new-cap
-          new Buffer.from(message),
+          message,
           key,
           Date.now(),
           opaque