search

microsoft / kafka-proxy-ws

A robust, scalable, high performance WebSockets based proxy for Kafka.
143 stars 37 forks source link

Topics fails to be delivered if one of the messages is empty #7

Open Photon89 opened 5 years ago

Photon89 commented 5 years ago

with following warning:

2018-10-01T10:12:56.694Z WARN no-kafka-client Handler for test:0 failed with TypeError: Cannot read property 'toString' of null
    at clients.(anonymous function).(anonymous function).ws.send.JSON.stringify.messageSet.map (/home/photon/kafka/nodejs-websocket/node_modules/kafka-proxy/lib/index.js:207:56)
    at Array.map (<anonymous>)
    at KafkaProxy._batchMessageHandler (/home/photon/kafka/nodejs-websocket/node_modules/kafka-proxy/lib/index.js:205:28)
    at Object.messageHandler (/home/photon/kafka/nodejs-websocket/node_modules/kafka-proxy/lib/index.js:297:68)
    at Object.consumers.(anonymous function).(anonymous function).subscribe (/home/photon/kafka/nodejs-websocket/node_modules/kafka-proxy/lib/index.js:155:56)
    at Object.tryCatcher (/home/photon/kafka/nodejs-websocket/node_modules/bluebird/js/release/util.js:16:23)
    at Object.handler (/home/photon/kafka/nodejs-websocket/node_modules/bluebird/js/release/method.js:15:34)
    at self.client.fetchRequest.map.concurrency (/home/photon/kafka/nodejs-websocket/node_modules/no-kafka/lib/base_consumer.js:66:26)
    at tryCatcher (/home/photon/kafka/nodejs-websocket/node_modules/bluebird/js/release/util.js:16:23)
    at MappingPromiseArray._promiseFulfilled (/home/photon/kafka/nodejs-websocket/node_modules/bluebird/js/release/map.js:61:38)
    at MappingPromiseArray.PromiseArray._iterate (/home/photon/kafka/nodejs-websocket/node_modules/bluebird/js/release/promise_array.js:114:31)
    at MappingPromiseArray.init (/home/photon/kafka/nodejs-websocket/node_modules/bluebird/js/release/promise_array.js:78:10)
    at Promise._settlePromise (/home/photon/kafka/nodejs-websocket/node_modules/bluebird/js/release/promise.js:566:21)
    at Promise._settlePromise0 (/home/photon/kafka/nodejs-websocket/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/home/photon/kafka/nodejs-websocket/node_modules/bluebird/js/release/promise.js:694:18)
    at Promise._fulfill (/home/photon/kafka/nodejs-websocket/node_modules/bluebird/js/release/promise.js:638:18)
    at MappingPromiseArray.PromiseArray._resolve (/home/photon/kafka/nodejs-websocket/node_modules/bluebird/js/release/promise_array.js:126:19)
    at MappingPromiseArray._promiseFulfilled (/home/photon/kafka/nodejs-websocket/node_modules/bluebird/js/release/map.js:101:18)
    at Promise._settlePromise (/home/photon/kafka/nodejs-websocket/node_modules/bluebird/js/release/promise.js:574:26)
    at Promise._settlePromise0 (/home/photon/kafka/nodejs-websocket/node_modules/bluebird/js/release/promise.js:614:10)
    at Promise._settlePromises (/home/photon/kafka/nodejs-websocket/node_modules/bluebird/js/release/promise.js:694:18)
    at _drainQueueStep (/home/photon/kafka/nodejs-websocket/node_modules/bluebird/js/release/async.js:138:12)