[ 
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)

Reply via email to