Add consumer message cache for KafkaJS compability mode

Author: milindl

examples/consumer.js

@@ -1,5 +1,4 @@
-const { Kafka, ErrorCodes } = require('../').KafkaJS
-
+const { Kafka, ErrorCodes } = require('confluent-kafka-javascript').KafkaJS;
 
 async function consumerStart() {
   let consumer;

examples/eos.js

@@ -1,5 +1,4 @@
-const { Kafka } = require('../').KafkaJS;
-//const { Kafka } = require('kafkajs')
+const { Kafka } = require('confluent-kafka-javascript').KafkaJS;
 
 async function eosStart() {
     const consumer = new Kafka().consumer({

examples/producer.js

@@ -1,5 +1,4 @@
-const { Kafka } = require('../').KafkaJS
-//const { Kafka } = require('kafkajs')
+const { Kafka } = require('confluent-kafka-javascript').KafkaJS;
 
 async function producerStart() {
     const producer = new Kafka().producer({