Kafka 的 kafka_2.10-0.10.2.2 版本,算是老牌组合里的稳定老将了,Scala 2.10 打底,配上 Kafka 0.10.2.2 的内核,兼容性和稳定性都挺不错的。你要是正好在搞 Storm 那一套,这版本用起来也顺手。

KafkaProducerConsumer API在这版本里算是比较成熟的,用起来不绕弯,响应也快。TopicPartition这些机制用来做实时稳,像日志收集、网站点击流那种场景,几乎标配。

配合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真心可以继续撑几年,省心省力。