gistfile1.txt

yarn run v1.5.1
$ make


  Producer

    ✓ required methods

    ✓ should create producer with default options

    ✓ should send a single message

    ✓ should send a single keyed message

    ✓ should fail when missing topic field

    ✓ should fail when missing partition field and no partitioner function defined

    ✓ should send an array of messages

    ✓ should return an error for unknown partition/topic and retry 5 times (454ms)

    ✓ partitioner arguments

    ✓ shoult throw when partitioner is not a function

    ✓ should determine topic partition using sync partitioner function

    ✓ should determine topic partition using async partitioner function (130ms)

    ✓ should throw error for unknown topic

    ✓ should group messages by global batch.size

    ✓ should not group messages with size > batch.size

    ✓ should group messages by batch.size in options

    ✓ should not group messages with different options

    ✓ should wait up to maxWait time (166ms)

  SimpleConsumer

    ✓ required methods
2018-04-04T17:13:47.003Z DEBUG simple-consumer Subscribed to kafka-test-topic:0 offset 116 leader 192.168.86.205:9092

    ✓ should receive new messages (123ms)
2018-04-04T17:13:47.125Z DEBUG simple-consumer Subscribed to kafka-test-topic:0 offset 117 leader 192.168.86.205:9092

    ✓ should receive new keyed messages (124ms)

    ✓ should correctly encode/decode utf8 string message value (119ms)

    ✓ offset() should return last offset
2018-04-04T17:13:47.371Z DEBUG simple-consumer Subscribed to kafka-test-topic:0 offset 319 leader 192.168.86.205:9092
2018-04-04T17:13:47.421Z WARN simple-consumer Updating offset because of OffsetOutOfRange error for kafka-test-topic:0

    ✓ should reset offset to LATEST on OffsetOutOfRange error (207ms)
2018-04-04T17:13:47.596Z DEBUG simple-consumer Subscribed to kafka-test-topic:0 offset 119 leader 192.168.86.205:9092

    ✓ should receive messages from specified offset (225ms)
2018-04-04T17:13:47.907Z DEBUG simple-consumer Subscribed to kafka-test-topic:0 offset 119 leader 192.168.86.205:9092

    1) should receive messages in maxBytes batches

    ✓ should be able to commit single offset

    ✓ should be able to commit offsets

    ✓ should be able to fetch commited offsets

    ✓ should unsubscribe all partitions in a topic when partition is not specified
2018-04-04T17:13:48.237Z DEBUG simple-consumer Subscribed to kafka-test-topic:0 offset 121 leader 192.168.86.205:9092
2018-04-04T17:13:48.237Z DEBUG simple-consumer Subscribed to kafka-test-topic:1 offset 15 leader 192.168.86.205:9092
2018-04-04T17:13:48.237Z DEBUG simple-consumer Subscribed to kafka-test-topic:2 offset 11 leader 192.168.86.205:9092

    ✓ should subscribe all partitions in a topic when partition is not specified
2018-04-04T17:13:48.239Z DEBUG simple-consumer Subscribed to kafka-test-topic:0 offset 121 leader 192.168.86.205:9092
2018-04-04T17:13:48.239Z DEBUG simple-consumer Subscribed to kafka-test-topic:1 offset 15 leader 192.168.86.205:9092

    ✓ should subscribe partitions specified as array
2018-04-04T17:13:48.240Z DEBUG simple-consumer Subscribed to kafka-test-topic:0 offset 121 leader 192.168.86.205:9092
2018-04-04T17:13:48.242Z DEBUG simple-consumer Subscribed to kafka-test-topic:1 offset 15 leader 192.168.86.205:9092

    ✓ should subscribe partitions specified as array when options specified
2018-04-04T17:13:48.243Z DEBUG simple-consumer Subscribed to kafka-test-topic:0 offset 121 leader 192.168.86.205:9092
2018-04-04T17:13:48.244Z DEBUG simple-consumer Subscribed to kafka-test-topic:1 offset 15 leader 192.168.86.205:9092
2018-04-04T17:13:48.244Z DEBUG simple-consumer Subscribed to kafka-test-topic:2 offset 11 leader 192.168.86.205:9092

    ✓ should subscribe all topic partitions when partition is not specified but options specified

    ✓ should throw when missing dataHandler function
2018-04-04T17:13:48.246Z DEBUG simple-consumer Subscribed to kafka-test-topic:0 offset 121 leader 192.168.86.205:9092
2018-04-04T17:13:48.327Z WARN simple-consumer Handler for kafka-test-topic:0 failed with Error
    at Object.<anonymous> (/Users/jdickey/src/github.com/hunterloftis/kafka/test/02.simple_consumer.js:339:19)
    at Function.invoke (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/sinon/lib/sinon/spy.js:176:59)
    at Object.proxy (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/sinon/lib/sinon/spy.js:85:30)
    at Object.tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Object.handler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/method.js:15:34)
    at self.client.fetchRequest.map.concurrency (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/base_consumer.js:9:2879)
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at MappingPromiseArray._promiseFulfilled (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/map.js:61:38)
    at MappingPromiseArray.PromiseArray._iterate (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:114:31)
    at MappingPromiseArray.init (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:78:10)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:566:21)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Promise._fulfill (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:638:18)
    at Promise._resolveCallback (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:432:57)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:524:17)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Promise._fulfill (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:638:18)
    at PromiseArray._resolve (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:126:19)
    at PromiseArray._promiseFulfilled (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:144:14)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:574:26)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:133:16)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5)

    ✓ should ignore sync errors in data handler (218ms)
2018-04-04T17:13:48.540Z DEBUG simple-consumer Subscribed to kafka-test-topic:0 offset 122 leader 192.168.86.205:9092
2018-04-04T17:13:48.650Z WARN simple-consumer Handler for kafka-test-topic:0 failed with Error
    at Object.<anonymous> (/Users/jdickey/src/github.com/hunterloftis/kafka/test/02.simple_consumer.js:356:35)
    at Function.invoke (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/sinon/lib/sinon/spy.js:176:59)
    at Object.proxy (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/sinon/lib/sinon/spy.js:85:30)
    at Object.tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Object.handler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/method.js:15:34)
    at self.client.fetchRequest.map.concurrency (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/base_consumer.js:9:2879)
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at MappingPromiseArray._promiseFulfilled (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/map.js:61:38)
    at MappingPromiseArray.PromiseArray._iterate (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:114:31)
    at MappingPromiseArray.init (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:78:10)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:566:21)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Promise._fulfill (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:638:18)
    at Promise._resolveCallback (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:432:57)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:524:17)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Promise._fulfill (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:638:18)
    at PromiseArray._resolve (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:126:19)
    at PromiseArray._promiseFulfilled (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:144:14)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:574:26)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:133:16)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5)

    ✓ should ignore async errors in data handler (292ms)

  GroupConsumer
2018-04-04T17:13:48.788Z INFO group-consumer1 Joined group no-kafka-group-v0.9 generationId 13 as group-consumer1-5af9a98e-c541-4552-b7b0-2db5b2fe2200
2018-04-04T17:13:48.788Z INFO group-consumer1 Elected as group leader
2018-04-04T17:13:48.797Z DEBUG group-consumer1 Subscribed to kafka-test-topic:0 offset 89 leader 192.168.86.205:9092
2018-04-04T17:13:48.797Z DEBUG group-consumer1 Subscribed to kafka-test-topic:1 offset 12 leader 192.168.86.205:9092
2018-04-04T17:13:48.797Z DEBUG group-consumer1 Subscribed to kafka-test-topic:2 offset 9 leader 192.168.86.205:9092
2018-04-04T17:13:48.874Z ERROR group-consumer1 Failed to decompress message at kafka-test-topic:0@91 TypeError: Expected a function
TypeError: Expected a function
    at createWrap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:5503:15)
    at Function.ary (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:10014:14)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:1446)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:2244)
    at Client._decompressMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:34185)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:18584
    at Array.forEach (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17676
    at Array.map (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17370
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:512:31)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Promise._fulfill (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:638:18)
    at PromiseArray._resolve (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:126:19)
    at PromiseArray._promiseFulfilled (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:144:14)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:574:26)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:133:16)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5)
    at createWrap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:5503:15)
    at Function.ary (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:10014:14)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:1446)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:2244)
    at Client._decompressMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:34185)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:18584
    at Array.forEach (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17676
    at Array.map (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17370
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:512:31)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Promise._fulfill (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:638:18)
    at PromiseArray._resolve (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:126:19)
    at PromiseArray._promiseFulfilled (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:144:14)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:574:26)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:133:16)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5) 
[at apply (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:470:17)]
2018-04-04T17:13:48.875Z ERROR group-consumer1 Failed to decompress message at kafka-test-topic:0@92 TypeError: Expected a function
TypeError: Expected a function
    at createWrap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:5503:15)
    at Function.ary (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:10014:14)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:1446)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:2244)
    at Client._decompressMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:34185)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:18584
    at Array.forEach (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17676
    at Array.map (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17370
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:512:31)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Promise._fulfill (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:638:18)
    at PromiseArray._resolve (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:126:19)
    at PromiseArray._promiseFulfilled (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:144:14)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:574:26)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:133:16)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5)
    at createWrap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:5503:15)
    at Function.ary (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:10014:14)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:1446)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:2244)
    at Client._decompressMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:34185)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:18584
    at Array.forEach (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17676
    at Array.map (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17370
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:512:31)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Promise._fulfill (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:638:18)
    at PromiseArray._resolve (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:126:19)
    at PromiseArray._promiseFulfilled (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:144:14)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:574:26)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:133:16)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5) 
[at apply (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:470:17)]
2018-04-04T17:13:48.876Z ERROR group-consumer1 Failed to decompress message at kafka-test-topic:0@93 TypeError: Expected a function
TypeError: Expected a function
    at createWrap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:5503:15)
    at Function.ary (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:10014:14)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:1446)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:2244)
    at Client._decompressMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:34185)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:18584
    at Array.forEach (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17676
    at Array.map (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17370
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:512:31)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Promise._fulfill (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:638:18)
    at PromiseArray._resolve (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:126:19)
    at PromiseArray._promiseFulfilled (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:144:14)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:574:26)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:133:16)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5)
    at createWrap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:5503:15)
    at Function.ary (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:10014:14)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:1446)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:2244)
    at Client._decompressMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:34185)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:18584
    at Array.forEach (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17676
    at Array.map (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17370
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:512:31)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Promise._fulfill (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:638:18)
    at PromiseArray._resolve (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:126:19)
    at PromiseArray._promiseFulfilled (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:144:14)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:574:26)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:133:16)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5) 
[at apply (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:470:17)]
2018-04-04T17:13:48.877Z ERROR group-consumer1 Failed to decompress message at kafka-test-topic:0@97 TypeError: Expected a function
TypeError: Expected a function
    at createWrap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:5503:15)
    at Function.ary (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:10014:14)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:1446)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:2244)
    at Client._decompressMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:34185)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:18584
    at Array.forEach (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17676
    at Array.map (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17370
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:512:31)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Promise._fulfill (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:638:18)
    at PromiseArray._resolve (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:126:19)
    at PromiseArray._promiseFulfilled (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:144:14)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:574:26)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:133:16)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5)
    at createWrap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:5503:15)
    at Function.ary (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:10014:14)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:1446)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:2244)
    at Client._decompressMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:34185)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:18584
    at Array.forEach (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17676
    at Array.map (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17370
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:512:31)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Promise._fulfill (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:638:18)
    at PromiseArray._resolve (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:126:19)
    at PromiseArray._promiseFulfilled (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:144:14)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:574:26)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:133:16)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5) 
[at apply (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:470:17)]
2018-04-04T17:13:48.877Z ERROR group-consumer1 Failed to decompress message at kafka-test-topic:0@98 TypeError: Expected a function
TypeError: Expected a function
    at createWrap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:5503:15)
    at Function.ary (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:10014:14)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:1446)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:2244)
    at Client._decompressMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:34185)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:18584
    at Array.forEach (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17676
    at Array.map (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17370
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:512:31)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Promise._fulfill (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:638:18)
    at PromiseArray._resolve (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:126:19)
    at PromiseArray._promiseFulfilled (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:144:14)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:574:26)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:133:16)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5)
    at createWrap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:5503:15)
    at Function.ary (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:10014:14)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:1446)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:2244)
    at Client._decompressMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:34185)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:18584
    at Array.forEach (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17676
    at Array.map (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17370
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:512:31)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Promise._fulfill (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:638:18)
    at PromiseArray._resolve (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:126:19)
    at PromiseArray._promiseFulfilled (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:144:14)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:574:26)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:133:16)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5) 
[at apply (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:470:17)]
2018-04-04T17:13:48.878Z ERROR group-consumer1 Failed to decompress message at kafka-test-topic:0@99 TypeError: Expected a function
TypeError: Expected a function
    at createWrap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:5503:15)
    at Function.ary (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:10014:14)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:1446)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:2244)
    at Client._decompressMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:34185)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:18584
    at Array.forEach (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17676
    at Array.map (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17370
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:512:31)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Promise._fulfill (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:638:18)
    at PromiseArray._resolve (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:126:19)
    at PromiseArray._promiseFulfilled (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:144:14)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:574:26)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:133:16)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5)
    at createWrap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:5503:15)
    at Function.ary (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:10014:14)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:1446)
    at Object.decompress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:2244)
    at Client._decompressMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:34185)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:18584
    at Array.forEach (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17676
    at Array.map (<anonymous>)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:17370
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:512:31)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Promise._fulfill (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:638:18)
    at PromiseArray._resolve (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:126:19)
    at PromiseArray._promiseFulfilled (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise_array.js:144:14)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:574:26)
    at Promise._settlePromise0 (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:693:18)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:133:16)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5) 
[at apply (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:470:17)]

    ✓ required methods

    ✓ should receive new messages (1041ms)

    ✓ should be able to commit offsets

    ✓ should be able to fetch commited offsets

    ✓ offset() should return last offset
2018-04-04T17:13:50.149Z INFO group-consumer1 Rejoining group on RebalanceInProgress
2018-04-04T17:13:50.152Z INFO group-consumer1 Joined group no-kafka-group-v0.9 generationId 14 as group-consumer1-5af9a98e-c541-4552-b7b0-2db5b2fe2200
2018-04-04T17:13:50.152Z INFO group-consumer1 Elected as group leader
2018-04-04T17:13:50.153Z INFO group-consumer3 Joined group no-kafka-group-v0.9 generationId 14 as group-consumer3-bd8fcb92-bbe0-4230-9509-4c7ffa275985
2018-04-04T17:13:50.156Z INFO group-consumer2 Joined group no-kafka-group-v0.9 generationId 14 as group-consumer2-e5d91dff-f823-4de4-86e4-b295aaeb4d3c
2018-04-04T17:13:50.162Z DEBUG group-consumer3 Subscribed to kafka-test-topic:0 offset 124 leader 192.168.86.205:9092
2018-04-04T17:13:50.163Z DEBUG group-consumer1 Subscribed to kafka-test-topic:1 offset 15 leader 192.168.86.205:9092
2018-04-04T17:13:50.163Z DEBUG group-consumer2 Subscribed to kafka-test-topic:2 offset 11 leader 192.168.86.205:9092

    ✓ should split partitions in a group (808ms)

    ✓ should not log errors on clean shutdown

  GroupAdmin
2018-04-04T17:13:50.921Z INFO group-consumer Joined group no-kafka-admin-test-group generationId 1 as group-consumer-d3cde492-f729-47ad-9aca-b9301c4df037
2018-04-04T17:13:50.921Z INFO group-consumer Elected as group leader
2018-04-04T17:13:50.946Z DEBUG group-consumer Subscribed to kafka-test-topic:0 offset 125 leader 192.168.86.205:9092
2018-04-04T17:13:50.947Z DEBUG group-consumer Subscribed to kafka-test-topic:1 offset 16 leader 192.168.86.205:9092
2018-04-04T17:13:50.947Z DEBUG group-consumer Subscribed to kafka-test-topic:2 offset 12 leader 192.168.86.205:9092

    ✓ required methods

    2) should list groups

    ✓ should describe group

  requiredAcks: 0
2018-04-04T17:13:50.960Z DEBUG simple-consumer Subscribed to kafka-test-topic:0 offset 125 leader 192.168.86.205:9092

    ✓ should send/receive messages (119ms)

  connectionString

    ✓ should throw when connectionString is wrong

  Weighted Round Robin Assignment
2018-04-04T17:13:51.090Z INFO group-consumer1 Joined group no-kafka-group-v0.9-wrr generationId 1 as group-consumer1-169751f5-a713-464d-be83-fc7feed91523
2018-04-04T17:13:51.090Z INFO group-consumer1 Elected as group leader
2018-04-04T17:13:51.091Z INFO group-consumer2 Joined group no-kafka-group-v0.9-wrr generationId 1 as group-consumer2-ff9591af-b96e-4140-9473-ee7f8725ad8d
2018-04-04T17:13:51.099Z DEBUG group-consumer1 Subscribed to kafka-test-topic:1 offset 16 leader 192.168.86.205:9092
2018-04-04T17:13:51.100Z DEBUG group-consumer2 Subscribed to kafka-test-topic:0 offset 126 leader 192.168.86.205:9092
2018-04-04T17:13:51.100Z DEBUG group-consumer2 Subscribed to kafka-test-topic:2 offset 12 leader 192.168.86.205:9092

    ✓ should split partitions according to consumer weight

  Consistent Assignment
2018-04-04T17:13:54.319Z INFO group-consumer1 Joined group no-kafka-group-v0.9-ring generationId 1 as group-consumer1-7f074b57-bc92-4dde-9575-4529485acade
2018-04-04T17:13:54.319Z INFO group-consumer1 Elected as group leader
2018-04-04T17:13:54.319Z INFO group-consumer2 Joined group no-kafka-group-v0.9-ring generationId 1 as group-consumer2-1ec087bd-4fdb-4429-b71f-49470193d298
2018-04-04T17:13:54.330Z DEBUG group-consumer1 Subscribed to kafka-test-topic:2 offset 12 leader 192.168.86.205:9092
2018-04-04T17:13:54.330Z DEBUG group-consumer2 Subscribed to kafka-test-topic:0 offset 126 leader 192.168.86.205:9092
2018-04-04T17:13:54.330Z DEBUG group-consumer2 Subscribed to kafka-test-topic:1 offset 16 leader 192.168.86.205:9092

    ✓ should split partitions according to consumer weight

  Compression
    sync
2018-04-04T17:13:57.568Z DEBUG simple-consumer Subscribed to kafka-test-topic:0 offset 126 leader 192.168.86.205:9092
2018-04-04T17:13:57.583Z WARN producer Failed to compress messageSet TypeError: Snappy.compress is not a function
    at Object.compress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:3587)
    at Client._compressMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:35499)
    at syncPartitionMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:13493)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3555:27
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4917:15
    at baseForOwn (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3002:24)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4886:18
    at baseMap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3554:7)
    at Function.map (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9546:14)
    at interceptor (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:16983:35)
    at Function.thru (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:8787:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4380:28
    at arrayReduce (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:675:21)
    at baseWrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4379:14)
    at LodashWrapper.wrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9042:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:14319
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3555:27
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4917:15
    at baseForOwn (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3002:24)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4886:18
    at baseMap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3554:7)
    at Function.map (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9546:14)
    at interceptor (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:16983:35)
    at Function.thru (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:8787:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4380:28
    at arrayReduce (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:675:21)
    at baseWrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4379:14)
    at LodashWrapper.wrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9042:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:14331
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:13392:38
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4917:15
    at baseForOwn (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3002:24)
    at Function.mapValues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:13391:7)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4380:28
    at arrayReduce (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:675:21)
    at baseWrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4379:14)
    at LodashWrapper.wrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9042:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:14342
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:512:31)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromiseCtx (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:606:10)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:138:12)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5)
2018-04-04T17:13:57.602Z WARN producer Failed to compress messageSet TypeError: Snappy.compress is not a function
    at Object.compress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:3587)
    at Client._compressMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:35499)
    at syncPartitionMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:13493)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3555:27
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4917:15
    at baseForOwn (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3002:24)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4886:18
    at baseMap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3554:7)
    at Function.map (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9546:14)
    at interceptor (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:16983:35)
    at Function.thru (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:8787:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4380:28
    at arrayReduce (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:675:21)
    at baseWrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4379:14)
    at LodashWrapper.wrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9042:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:14319
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3555:27
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4917:15
    at baseForOwn (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3002:24)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4886:18
    at baseMap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3554:7)
    at Function.map (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9546:14)
    at interceptor (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:16983:35)
    at Function.thru (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:8787:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4380:28
    at arrayReduce (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:675:21)
    at baseWrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4379:14)
    at LodashWrapper.wrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9042:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:14331
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:13392:38
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4917:15
    at baseForOwn (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3002:24)
    at Function.mapValues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:13391:7)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4380:28
    at arrayReduce (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:675:21)
    at baseWrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4379:14)
    at LodashWrapper.wrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9042:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:14342
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:512:31)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromiseCtx (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:606:10)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:138:12)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5)
2018-04-04T17:13:57.606Z DEBUG simple-consumer Subscribed to kafka-test-topic:0 offset 126 leader 192.168.86.205:9092

      ✓ should send/receive with Snappy compression (<32kb) (239ms)
2018-04-04T17:13:57.815Z WARN producer Failed to compress messageSet TypeError: Snappy.compress is not a function
    at Object.compress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:3587)
    at Client._compressMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:35499)
    at syncPartitionMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:13493)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3555:27
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4917:15
    at baseForOwn (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3002:24)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4886:18
    at baseMap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3554:7)
    at Function.map (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9546:14)
    at interceptor (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:16983:35)
    at Function.thru (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:8787:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4380:28
    at arrayReduce (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:675:21)
    at baseWrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4379:14)
    at LodashWrapper.wrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9042:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:14319
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3555:27
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4917:15
    at baseForOwn (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3002:24)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4886:18
    at baseMap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3554:7)
    at Function.map (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9546:14)
    at interceptor (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:16983:35)
    at Function.thru (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:8787:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4380:28
    at arrayReduce (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:675:21)
    at baseWrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4379:14)
    at LodashWrapper.wrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9042:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:14331
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:13392:38
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4917:15
    at baseForOwn (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3002:24)
    at Function.mapValues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:13391:7)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4380:28
    at arrayReduce (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:675:21)
    at baseWrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4379:14)
    at LodashWrapper.wrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9042:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:14342
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:512:31)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromiseCtx (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:606:10)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:138:12)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5)

      ✓ should send/receive with Snappy compression (>32kb) (315ms)

      ✓ should send/receive with gzip compression (223ms)
2018-04-04T17:13:58.362Z WARN producer Failed to compress messageSet Error: Unsupported compression codec 30
    at Object.compress (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:4028)
    at Client._compressMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:35499)
    at syncPartitionMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:13493)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3555:27
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4917:15
    at baseForOwn (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3002:24)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4886:18
    at baseMap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3554:7)
    at Function.map (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9546:14)
    at interceptor (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:16983:35)
    at Function.thru (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:8787:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4380:28
    at arrayReduce (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:675:21)
    at baseWrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4379:14)
    at LodashWrapper.wrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9042:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:14319
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3555:27
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4917:15
    at baseForOwn (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3002:24)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4886:18
    at baseMap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3554:7)
    at Function.map (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9546:14)
    at interceptor (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:16983:35)
    at Function.thru (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:8787:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4380:28
    at arrayReduce (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:675:21)
    at baseWrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4379:14)
    at LodashWrapper.wrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9042:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:14331
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:13392:38
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4917:15
    at baseForOwn (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3002:24)
    at Function.mapValues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:13391:7)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4380:28
    at arrayReduce (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:675:21)
    at baseWrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4379:14)
    at LodashWrapper.wrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9042:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:14342
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:512:31)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromiseCtx (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:606:10)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:138:12)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5)

      ✓ producer should send uncompressed message when codec is not supported (219ms)
    async
2018-04-04T17:13:58.576Z DEBUG simple-consumer Subscribed to kafka-test-topic:0 offset 132 leader 192.168.86.205:9092

      3) should send/receive with async Snappy compression (<32kb)

      4) should send/receive with async Snappy compression (>32kb)

      ✓ should send/receive with async gzip compression (225ms)

      ✓ should send/receive with async Gzip compression (>32kb) (307ms)
2018-04-04T17:14:03.131Z WARN producer Failed to compress messageSet Error: Unsupported compression codec 30
    at Object.compressAsync (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/protocol/misc/compression.js:9:4652)
    at Client._compressMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:34937)
    at asyncPartitionMessageSet (/Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:12976)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3555:27
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4917:15
    at baseForOwn (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3002:24)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4886:18
    at baseMap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3554:7)
    at Function.map (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9546:14)
    at interceptor (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:16983:35)
    at Function.thru (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:8787:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4380:28
    at arrayReduce (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:675:21)
    at baseWrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4379:14)
    at LodashWrapper.wrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9042:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:14319
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3555:27
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4917:15
    at baseForOwn (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3002:24)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4886:18
    at baseMap (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3554:7)
    at Function.map (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9546:14)
    at interceptor (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:16983:35)
    at Function.thru (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:8787:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4380:28
    at arrayReduce (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:675:21)
    at baseWrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4379:14)
    at LodashWrapper.wrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9042:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:14331
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:13392:38
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4917:15
    at baseForOwn (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:3002:24)
    at Function.mapValues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:13391:7)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4380:28
    at arrayReduce (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:675:21)
    at baseWrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:4379:14)
    at LodashWrapper.wrapperValue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/lodash/lodash.js:9042:14)
    at /Users/jdickey/src/github.com/hunterloftis/kafka/lib/client.js:9:14342
    at tryCatcher (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/util.js:16:23)
    at Promise._settlePromiseFromHandler (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:512:31)
    at Promise._settlePromise (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:569:18)
    at Promise._settlePromiseCtx (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/promise.js:606:10)
    at Async._drainQueue (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:138:12)
    at Async._drainQueues (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:143:10)
    at Immediate.Async.drainQueues [as _onImmediate] (/Users/jdickey/src/github.com/hunterloftis/kafka/node_modules/bluebird/js/release/async.js:17:14)
    at runCallback (timers.js:763:18)
    at tryOnImmediate (timers.js:734:5)
    at processImmediate (timers.js:716:5)

      ✓ producer should send uncompressed message when codec is not supported (219ms)

  Connection
2018-04-04T17:14:03.348Z DEBUG simple-consumer Subscribed to kafka-test-topic:0 offset 135 leader 192.168.86.205:9092

    ✓ should be able to grow receive buffer (308ms)

    ✓ should parse connection string with protocol

    ✓ should parse connection string without protocol

    ✓ should parse connection string with multiple hosts with and without protocol

    ✓ should parse connection string with multiple hosts without protocol

    ✓ should strip whitespaces in connectionString


  62 passing (18s)
  4 failing

  1) SimpleConsumer should receive messages in maxBytes batches:
     AssertionError: expected spy to have been called exactly twice, but it was called 0 times
      at test/02.simple_consumer.js:183:53
      at tryCatcher (node_modules/bluebird/js/release/util.js:16:23)
      at Promise._settlePromiseFromHandler (node_modules/bluebird/js/release/promise.js:512:31)
      at Promise._settlePromise (node_modules/bluebird/js/release/promise.js:569:18)
      at Promise._settlePromise0 (node_modules/bluebird/js/release/promise.js:614:10)
      at Promise._settlePromises (node_modules/bluebird/js/release/promise.js:693:18)
      at Promise._fulfill (node_modules/bluebird/js/release/promise.js:638:18)
      at Promise._resolveCallback (node_modules/bluebird/js/release/promise.js:432:57)
      at Promise._settlePromiseFromHandler (node_modules/bluebird/js/release/promise.js:524:17)
      at Promise._settlePromise (node_modules/bluebird/js/release/promise.js:569:18)
      at Promise._settlePromise0 (node_modules/bluebird/js/release/promise.js:614:10)
      at Promise._settlePromises (node_modules/bluebird/js/release/promise.js:693:18)
      at Promise._fulfill (node_modules/bluebird/js/release/promise.js:638:18)
      at Timeout._onTimeout (node_modules/bluebird/js/release/timers.js:26:46)

  2) GroupAdmin should list groups:
     AssertionError: expected [ Array(3) ] to have a length of 1 but got 3
      at test/04.group_admin.js:47:51
      at tryCatcher (node_modules/bluebird/js/release/util.js:16:23)
      at Promise._settlePromiseFromHandler (node_modules/bluebird/js/release/promise.js:512:31)
      at Promise._settlePromise (node_modules/bluebird/js/release/promise.js:569:18)
      at Promise._settlePromise0 (node_modules/bluebird/js/release/promise.js:614:10)
      at Promise._settlePromises (node_modules/bluebird/js/release/promise.js:693:18)
      at Promise._fulfill (node_modules/bluebird/js/release/promise.js:638:18)
      at Promise._resolveCallback (node_modules/bluebird/js/release/promise.js:432:57)
      at Promise._settlePromiseFromHandler (node_modules/bluebird/js/release/promise.js:524:17)
      at Promise._settlePromise (node_modules/bluebird/js/release/promise.js:569:18)
      at Promise._settlePromise0 (node_modules/bluebird/js/release/promise.js:614:10)
      at Promise._settlePromises (node_modules/bluebird/js/release/promise.js:693:18)
      at Promise._fulfill (node_modules/bluebird/js/release/promise.js:638:18)
      at MappingPromiseArray.PromiseArray._resolve (node_modules/bluebird/js/release/promise_array.js:126:19)
      at MappingPromiseArray._promiseFulfilled (node_modules/bluebird/js/release/map.js:101:18)
      at Promise._settlePromise (node_modules/bluebird/js/release/promise.js:574:26)
      at Promise._settlePromise0 (node_modules/bluebird/js/release/promise.js:614:10)
      at Promise._settlePromises (node_modules/bluebird/js/release/promise.js:693:18)
      at Async._drainQueue (node_modules/bluebird/js/release/async.js:133:16)
      at Async._drainQueues (node_modules/bluebird/js/release/async.js:143:10)
      at Immediate.Async.drainQueues [as _onImmediate] (node_modules/bluebird/js/release/async.js:17:14)

  3) Compression async should send/receive with async Snappy compression (<32kb):
     Error: timeout of 2000ms exceeded. Ensure the done() callback is being called in this test.
  

  4) Compression async should send/receive with async Snappy compression (>32kb):
     Error: timeout of 2000ms exceeded. Ensure the done() callback is being called in this test.
  



=============================================================================
Writing coverage object [/Users/jdickey/src/github.com/hunterloftis/kafka/coverage/coverage.json]
Writing coverage reports at [/Users/jdickey/src/github.com/hunterloftis/kafka/coverage]
=============================================================================
-------------------------|----------|----------|----------|----------|----------------|
File                     |  % Stmts | % Branch |  % Funcs |  % Lines |Uncovered Lines |
-------------------------|----------|----------|----------|----------|----------------|
 lib/                    |    92.42 |    82.33 |    90.26 |    92.52 |                |
  base_consumer.js       |    95.76 |    93.48 |    93.33 |    95.76 |... 110,142,230 |
  bluebird-configured.js |      100 |      100 |      100 |      100 |                |
  client.js              |    89.86 |    76.19 |    89.72 |    90.14 |... 541,586,607 |
  connection.js          |    92.63 |    78.57 |       95 |    92.63 |... 1,82,83,170 |
  errors.js              |    84.62 |    58.33 |       60 |    84.62 |... ,92,111,119 |
  group_admin.js         |      100 |      100 |      100 |      100 |                |
  group_consumer.js      |    88.24 |    78.95 |    83.33 |    88.24 |... 217,284,309 |
  index.js               |    97.87 |       50 |      100 |    97.87 |             22 |
  producer.js            |      100 |    97.87 |      100 |      100 |                |
  simple_consumer.js     |      100 |     87.5 |      100 |      100 |                |
 lib/protocol/           |    99.25 |    92.86 |      100 |    99.25 |                |
  admin.js               |      100 |       50 |      100 |      100 |                |
  common.js              |    98.78 |    96.88 |      100 |    98.78 |             74 |
  fetch.js               |      100 |      100 |      100 |      100 |                |
  globals.js             |      100 |      100 |      100 |      100 |                |
  group_membership.js    |    98.48 |       50 |      100 |    98.48 |            198 |
  index.js               |      100 |      100 |      100 |      100 |                |
  metadata.js            |      100 |      100 |      100 |      100 |                |
  offset.js              |      100 |      100 |      100 |      100 |                |
  offset_commit_fetch.js |      100 |      100 |      100 |      100 |                |
  produce.js             |      100 |      100 |      100 |      100 |                |
 lib/protocol/misc/      |       95 |    81.82 |    85.71 |    94.87 |                |
  compression.js         |       95 |    81.82 |    85.71 |    94.87 |          40,70 |
-------------------------|----------|----------|----------|----------|----------------|
All files                |    94.08 |    83.57 |    92.58 |    94.15 |                |
-------------------------|----------|----------|----------|----------|----------------|


=============================== Coverage summary ===============================
Statements   : 94.08% ( 1097/1166 ), 26 ignored
Branches     : 83.57% ( 290/347 ), 6 ignored
Functions    : 92.58% ( 337/364 ), 14 ignored
Lines        : 94.15% ( 1095/1163 )
================================================================================
make: *** [test] Error 4
error An unexpected error occurred: "Command failed.
Exit code: 2
Command: sh
Arguments: -c make
Directory: /Users/jdickey/src/github.com/hunterloftis/kafka
Output:
".
info If you think this is a bug, please open a bug report with the information provided in "/Users/jdickey/src/github.com/hunterloftis/kafka/yarn-error.log".
info Visit https://yarnpkg.com/en/docs/cli/run for documentation about this command.