Migrate away from Travis ci

.github/workflows/ci.yml

@@ -1,4 +1,3 @@
-
 name: CI
 
 on:
@@ -13,21 +12,19 @@ jobs:
     strategy:
       matrix:
         node-version: [10.x, 12.x, 14.x]
-    services:
-      kafka:
-        image: confluentinc/cp-kafka
-        ports:
-        - 9092:9092
     steps:
-    - uses: actions/checkout@v2
-    - name: Use Node.js ${{ matrix.node-version }}
-      uses: actions/[email protected]
-      with:
-        node-version: ${{ matrix.node-version }}
-    - name: Install Dependencies
-      run: npm install --ignore-scripts
-    - name: Test
-      run: npm test
+      # - uses: actions/checkout@v2
+      # - name: Build the Kafka
+      - name: Use Node.js ${{ matrix.node-version }}
+        uses: actions/[email protected]
+        with:
+          node-version: ${{ matrix.node-version }}
+      - name: Install Dependencies
+        run: npm install --ignore-scripts
+      - name: Build container
+        run: docker-compose up -d
+      - name: Test
+        run: npm test
 
 
   automerge:

lib/consumer.js

@@ -7,7 +7,7 @@ const Kafka = require('node-rdkafka')
 function Consumer (opts, log, next, topicConf, metadatOptions) {
   this._log = log
   this.consumer = new Kafka.KafkaConsumer(opts, topicConf || {})
-  var calledNext = false
+  let calledNext = false
 
   this.consumer.once('ready', onReady.bind(this))
   this.consumer.on('event.error', onError.bind(this))

lib/producer.js

@@ -8,7 +8,7 @@ function Producer (opts, log, next, topicConf, metadatOptions) {
   this._log = log
   this.producer = new Kafka.Producer(opts, topicConf || {})
 
-  var calledNext = false
+  let calledNext = false
 
   this.producer.once('ready', onReady.bind(this))
   this.producer.on('event.error', onError.bind(this))