You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Manikumar (JIRA)" <ji...@apache.org> on 2018/07/21 07:03:00 UTC

[jira] [Resolved] (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 ]

Manikumar resolved KAFKA-2008.
------------------------------
    Resolution: Auto Closed

Closing issue related old consumer configs. Old consumer config doc section will be removed.

> 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
>            Priority: Major
>
> 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
(v7.6.3#76005)