Apacke卡夫卡监听器螺纹

卡夫卡总是给一个分区的数据一个消费者线

为限制在线程数 20 与 150 分区，可以设置并发到 8 这应该有效地创建8个独立的消费情况&限制线数到一个最大的 <19 (150/8).

这 是另一个堆栈后在该专题这就解释了这一点更为设定并发卡夫卡在你的监听器工厂。 还 这 是另一个体面的来源，用于说明的一些概念围绕卡夫卡主题及分区。

1. 如果你想要 最大限度地消费的，是的，你需要150 consumer threads 在150 partitions (1消费者线每分区)。 在情况下你只有20,你不能要 最大限度地消费，而不是的，现在1消费者负责消耗例如150/20=7 partitions. 这是一个折衷。

2. 你不会想你的应用消耗50 topics 在一段时间。 这导致了规模问题。 我们现在说一个话题，需要数目的增加它的 partitions 午3时至6时，你的水平的规模应用从1到2个实例，这意味着从150 consumers 到300 consumers 只有150+(6-3)=153活动 consumers其他人成为闲置。