Kafka Streams [1]¶

Kafka Streams是一个Java库，而不是一个流处理框架，这点和Strom等流处理框架有明显地不同

Kafka Streams直接解决了在流处理中会遇到的很多难题:

一次一件事件的处理(而不是microbatch)，延迟在毫秒
有状态的处理，包括分布式join和aggregation
一个方便的DSL
使用类似于DataFlow的模型来处理乱序数据的windowing问题
分布式处理，并且有容错机制，可以快速地实现failover
有重新处理数据的能力，所以当你的代码更改后，你可以重新计算输出。
没有不可用时间的滚动布署

Kafka Streams是一个用来构建流处理程序的库，特别是其输入是一个Kafka topic，输出是另一个Kafka topic的程序(或者是调用外部服务，或者是更新数据库，或者其它)

在流处理领域有很多正在进行的有趣的工作，包括像 Apache Spark [2] , Apache Storm [3] ,Apache Flink [4] ,和 Apache Samza [5] 这样的的开源框架，也包括像Google’s DataFlow [6] 和 AWS Lambda [7] 一样的专有服务