kafka学习笔记 - Consumer开发的一些关键点
Closed this issue · 0 comments
wangzz719 commented
负载低的情况下可以每个线程消费多个partition。但负载高的情况下,Consumer 线程数最好和Partition数量保持一致。如果还是消费不过来,应该再开 Consumer 进程,进程内线程数同样和分区数一致。
这里应该是 consumer 进程 pull 下来交给线程来处理消息吧?
Closed this issue · 0 comments
负载低的情况下可以每个线程消费多个partition。但负载高的情况下,Consumer 线程数最好和Partition数量保持一致。如果还是消费不过来,应该再开 Consumer 进程,进程内线程数同样和分区数一致。
这里应该是 consumer 进程 pull 下来交给线程来处理消息吧?