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