SOHU-Co / kafka-node

87%

master: 89%

LAST BUILD ON BRANCH consumergroup-deploy-recover

branch: consumergroup-deploy-recover

CHANGE BRANCH

x

Reset

• consumergroup-deploy-recover
• 0.11-kafka-docker
• 1.0.2-release
• 1.1.0-release
• 1.2.0-release
• add-issue-template
• add-kafka-2-docker
• add-magicbyte-doc
• add-node-10
• add-node-7-travis
• add-node-8
• add-node-9-travis
• add-test-verify-autoCommit
• add-updateOffset-test
• alkarex-fix
• allow-broker-idle-disconnect
• allow-leave-to-fail-on-close
• api_versions_support
• binary-docs
• broker-offline-recovery
• ci-changes
• consumer-streams
• consumerGroup-offsetOutOfRange
• delete-idle-brokers
• denque
• destroyed-closed-broker-sockets
• do-not-fetch-while-closing
• doc-fixes
• doc-update
• drop-6-add-12
• empty-api-support
• expose-cg-errors
• fetch-timestamps
• fix-950
• fix-apiSupport-empty
• fix-blocked-fetch-loop
• fix-cb-not-func-in-cg
• fix-cg-offset
• fix-cg-uncaught-exception
• fix-cgs-autoCommit
• fix-cgs-test-failure
• fix-cgstream-commit-offset
• fix-clearing-cb-queue
• fix-comsumer-offset-commit
• fix-consumer-example
• fix-consumerGroup-fromOffset
• fix-controllerId-falsey-check
• fix-createTopics-sync
• fix-deprecated-sinon
• fix-docker-compose
• fix-docs
• fix-duplicate-messages
• fix-eslint-plugin
• fix-event-emitter-leak-test
• fix-fetchOffset
• fix-hlc-migrator-offset
• fix-hlc-migrator-offset2
• fix-initial-connect-loadMetadata
• fix-int32-bounds
• fix-invalid-broker-reconnect
• fix-kafkaClient-ready
• fix-killed-broker-crash
• fix-leave-group-exception
• fix-message-decoding
• fix-message-exceeding-maxBytes
• fix-message-key
• fix-out-of-range
• fix-parse-hosts
• fix-producer-send-callback-issue
• fix-stalled-partitions
• fix-test-failure
• fix-topic-already-exists-failure
• fix-topic-partition-check
• fix-typos
• fix-typos2
• fix-updateMetadata
• heartbeat-error-recover
• heartbeat-refactor
• improve-consumer-recovery
• improve-doc
• improve-test-stability
• kafka-0.11-support
• kafka-client
• large-message-test
• leftover-zk
• list-all-topics-doc
• master
• multi-version-kafka-test
• network-error-recovery
• no-refresh-on-idle
• offset-unhandled-error
• payload-normalize
• producer-broker-recovery
• producer-stream
• producer-v1-2
• re-enable-tests
• refresh-broker-metadata-on-close
• refresh-metadata-producer-send
• remove-error
• remove-node-4
• remove-node5-nobody-uses-it
• remove-nsp
• remove-spammy-logs
• remove-travis-node-7
• remove-zookeeper
• restore-dedicated-fetch-socket
• revert-bl-change
• test-for-pr-1066
• test-issue-1225
• throw-on-unknown-magic
• topic-partition-detection
• troubleshoot-cgs-test
• unpend-tests
• update-dependencies
• update-devDependencies
• update-engines
• update-eslint-deps
• update-readme-offset-warning
• update-topic-doc
• upgrade-async
• upgrade-lodash4
• v1.0-release
• v1.0.0
• v1.0.1
• v1.0.1-release
• v1.0.2
• v1.0.3
• v1.0.3-release
• v1.0.4-release
• v1.0.6-release
• v1.0.7
• v1.0.7-release
• v1.1.0
• v1.2.0
• v1.3.0
• v1.3.0-release
• v1.3.1
• v1.3.1-release
• v1.3.3-release
• v1.4.0-release
• v1.5.0-release
• v1.6.0
• v1.6.0-release
• v1.6.1
• v1.6.1-release
• v1.6.2
• v1.6.2-release
• v2.0.1
• v2.0.1-release
• v2.1.0
• v2.1.0-release
• v2.2.0
• v2.2.0-release
• v2.2.1
• v2.2.2
• v2.2.2-release
• v2.2.3
• v2.3.0
• v2.3.1
• v2.3.2-release
• v2.4.0
• v2.4.1
• v2.5.0
• v2.6.0
• v2.6.1
• v3.0.0
• v3.0.1
• v4.0.0
• v4.0.1
• v4.0.2
• v4.0.3
• v4.1.1
• v4.1.2
• v4.1.3
• v5.0.0
• verify-cyclic-partitioner

Add a check for broker connection is still active before checking broker is ready