SOHU-Co / kafka-node

Node.js client for Apache Kafka 0.8 and later.
MIT License
2.66k stars 627 forks source link

Error: Unable to assemble data #1002

Open thynson opened 6 years ago

thynson commented 6 years ago

Questions?

We recently struggled with a HighLevelComsumer error, with message "Unable to assemble data", raised from here. What could be the reason cause such error, or it's a bug of this library? stacktrace:

FailedToRebalanceConsumerError
    at new FailedToRebalanceConsumerError (/home/git/xxxxxxxxxxxx/node_modules/_kafka-node@2.6.1@kafka-node/lib/errors/FailedToRebalanceConsumerError.js:11:9)
    at /home/git/xxxxxxxxxxxx/node_modules/_kafka-node@2.6.1@kafka-node/lib/highLevelConsumer.js:190:39
    at /home/git/xxxxxxxxxxxx/node_modules/_kafka-node@2.6.1@kafka-node/lib/highLevelConsumer.js:490:9
    at /home/git/xxxxxxxxxxxx/node_modules/_async@2.6.1@async/dist/async.js:3888:9
    at /home/git/xxxxxxxxxxxx/node_modules/_async@2.6.1@async/dist/async.js:473:16
    at iterateeCallback (/home/git/xxxxxxxxxxxx/node_modules/_async@2.6.1@async/dist/async.js:988:17)
    at /home/git/xxxxxxxxxxxx/node_modules/_async@2.6.1@async/dist/async.js:969:16
    at /home/git/xxxxxxxxxxxx/node_modules/_async@2.6.1@async/dist/async.js:3885:13
    at /home/git/xxxxxxxxxxxx/node_modules/_kafka-node@2.6.1@kafka-node/lib/highLevelConsumer.js:381:11
    at /home/git/xxxxxxxxxxxx/node_modules/_kafka-node@2.6.1@kafka-node/lib/zookeeper.js:217:9
    at /home/git/xxxxxxxxxxxx/node_modules/_async@2.6.1@async/dist/async.js:3888:9
    at /home/git/xxxxxxxxxxxx/node_modules/_async@2.6.1@async/dist/async.js:473:16
    at iterateeCallback (/home/git/xxxxxxxxxxxx/node_modules/_async@2.6.1@async/dist/async.js:988:17)
    at /home/git/xxxxxxxxxxxx/node_modules/_async@2.6.1@async/dist/async.js:969:16
    at /home/git/xxxxxxxxxxxx/node_modules/_async@2.6.1@async/dist/async.js:3885:13
    at /home/git/xxxxxxxxxxxx/node_modules/_kafka-node@2.6.1@kafka-node/lib/zookeeper.js:170:19

Environment

For specific cases also provide

Include Sample Code to reproduce behavior

Thanks for your contribution!

hyperlink commented 6 years ago

Have you tried using KafkaClient instead of Client?