这家伙太懒,什么都没留下
多线程,另外你这个场景概率很低被使用,基本上topic里的消息格式都不同,无法共用。
嗯,上面只是举个例子。多启动几个程序。每个程序也可以选择,一个线程订阅一个topic,或者多个线程统一订阅所有topic。你觉得哪种更好?
一个程序没必要用那么多线程吧,逻辑复杂增加很多。kafka是批量拉取消息的,一次拉取1000-2000条,处理的时候可以考虑多线程处理。(springboot kafka有现成的实现)
我推荐如果想分摊压力,多启动几个程序。毕竟单台机器的cpu有限,可以在不同的机器分别启动程序。
这个就成分布式的了,逻辑简单,容错率高。