并非所有基于流的应用程序都需要处理集群,轻量级、简单易用的Kafka Streams库提供了微服务和实时事件处理中进行消息处理所需的强大功能。使用Kafka Streams API,只需使用Kafka及相应的流式应用程序可以对数据流进行过滤和转换。
本书教读者在Kafka平台上实现流式处理。在这本易于理解的书中,读者将通过实际的例子来收集、转换和聚合数据,使用多个处理器,处理实时事件,可以使用KSQL 深入研究流式SQL。本书还讲解了Kafka Streams应用程序的测试和运维方面的内容(如监控和调试)。
本书主要内容
● 使用KStream API。
● 过滤、转换和拆分数据。
● 使用处理器API。
● 与外部系统集成。
如果读者具备分布式系统的一些经验,那么Kafka或流式应用程序的知识并不是必需的。