[ 
https://issues.apache.org/jira/browse/KAFKA-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

TAO XIAO updated KAFKA-2008:
----------------------------
    Description: 
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 per 
broker. 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

  }

  was:
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

  }


> 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 per 
> broker. 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