1

在 Kafka 的旧消费者配置中,有一个属性num.consumer.fetchers可以配置用于获取数据的获取线程数。在 Kafka 的新消费者配置中,是否有任何具有相同功能的属性?如果没有,新消费者是如何解决这个问题的?

4

1 回答 1

2

新的消费者是单线程的(不包括后台心跳线程),所以没有提供等效的配置。

顺便说一句,'num.consumer.fetchers' 没有像文档所说的那样指定 fetcher 线程的数量。它实际上控制了 Kafka 可以创建的 fetcher 线程的可能最大数量。

于 2017-01-19T02:09:49.247 回答