GitHub user amethystic opened a pull request: https://github.com/apache/kafka/pull/2606
kafka4811: ReplicaFetchThread may fail to create due to existing metric Have fetcherThreadMap keyed off brokerId + fetcherId instead of broker + fetcherId, but did not consider the case where port is changed. You can merge this pull request into a Git repository by running: $ git pull https://github.com/amethystic/kafka kafka4811_ReplicaFetchThread_fail_create Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2606.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #2606 ---- commit b153d15f558b642e2c839ac99cf5e06c130f3497 Author: huxi <h...@zhenrongbao.com> Date: 2017-02-28T05:33:52Z kafka4811: ReplicaFetchThread may fail to create due to existing metric Have fetcherThreadMap keyed off brokerId + fetcherId instead of broker + fetcherId ---- --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---