TAO XIAO created KAFKA-2008:
-------------------------------
Summary: 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
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)
