Kafka 的 kafka_2.10-0.10.2.2 版本,算是老牌组合里的稳定老将了,Scala 2.10 打底,配上 Kafka 0.10.2.2 的内核,兼容性和稳定性都挺不错的。你要是正好在搞 Storm 那一套,这版本用起来也顺手。
Kafka的Producer和Consumer API在这版本里算是比较成熟的,用起来不绕弯,响应也快。Topic、Partition这些机制用来做实时稳,像日志收集、网站点击流那种场景,几乎标配。
配合Apache Storm 1.2.2用也挺香的,Kafka 做中间件,Storm 负责消费和。像你要做个实时统计系统,Kafka 接收数据,Storm 直接输出,比如用户行为实时、风控预警啥的,一整套串下来,还挺顺的。
Storm的拓扑配置其实也不算复杂,nimbus
搞主控,supervisor
扛计算,资源规划一下就行。尤其这套组合,高并发数据流靠谱,关键还能扩展。
要注意版本配合的问题,Kafka 0.10.2.2 对一些新版组件兼容性没那么好,不过在一些老项目或者资源紧张的环境下,还是实用的。
如果你现在还在用老版本的 Scala 项目,这套kafka_2.10-0.10.2.2
真心可以继续撑几年,省心省力。