Merge pull request #62 from imnotjames/bugfix/js-kafka-client-buffers

use 'buffer' for default JS Kafka encoding
nodefluent · Jun 15, 2018 · c19f1b3 · c19f1b3
2 parents afddba8 + 5d28f54
commit c19f1b3
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/lib/kafka/Kafka.js b/lib/kafka/Kafka.js
@@ -180,7 +180,9 @@ class Kafka extends EventEmitter {
       fetchMaxWaitMs: 100,
       autoCommit: autoCommit,
       autoCommitIntervalMs: 5000,
-      connectRetryOptions: this.connectDirectlyToBroker ? DEFAULT_RETRY_OPTIONS : undefined
+      connectRetryOptions: this.connectDirectlyToBroker ? DEFAULT_RETRY_OPTIONS : undefined,
+      encoding: "buffer",
+      keyEncoding: "buffer"
     };
 
     //overwrite default options