superhj1987/superhj1987.github.io

kafka学习笔记 - Consumer开发的一些关键点

Closed this issue · 0 comments

负载低的情况下可以每个线程消费多个partition。但负载高的情况下,Consumer 线程数最好和Partition数量保持一致。如果还是消费不过来,应该再开 Consumer 进程,进程内线程数同样和分区数一致。

这里应该是 consumer 进程 pull 下来交给线程来处理消息吧?