You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "TAO XIAO (JIRA)" <ji...@apache.org> on 2015/03/07 10:08:38 UTC
[jira] [Updated] (KAFKA-2008) Update num.consumer.fetchers
description in Kafka documentation
[ https://issues.apache.org/jira/browse/KAFKA-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
TAO XIAO updated KAFKA-2008:
----------------------------
Affects Version/s: 0.8.2.0
> Update num.consumer.fetchers description in Kafka documentation
> ---------------------------------------------------------------
>
> Key: KAFKA-2008
> URL: https://issues.apache.org/jira/browse/KAFKA-2008
> Project: Kafka
> Issue Type: Improvement
> Components: website
> Affects Versions: 0.8.2.0
> Reporter: TAO XIAO
>
> The description of num.consumer.fetchers currently shown in consumer config section of Kafka document is not accurate.
> num.consumer.fetchers actually controls the max number of fetcher threads that can be created in consumer. The actual number of fetcher threads is controlled by the combination of topic, partition and num.consumer.fetchers
> Reference source code in AbstractFetcherManager
> private def getFetcherId(topic: String, partitionId: Int) : Int = {
> Utils.abs(31 * topic.hashCode() + partitionId) % numFetchers
> }
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)