Apache Kafka发布新版本支持Streams API

Apache Kafka发布了新的版本，为会话窗口提供了一个新的Kafka Streams API，并提高了Java用户端的兼容性。 Apache Kafka是一个分布式流式平台，可用于在系统或者应用程序之间构建实时流式数据管道。

除了新的Streams API之外，对此版本的其余改进还包括提高Java用户端的兼容性，改进Kafka Streams连接的语义以及Kafka Connect中的单个消息转换。

Kafka最初是由LinkedIn开发的，并开始作为Apache项目。它是一种快速，可扩展，持久和容错的订阅消息传递系统，可用于代替传统的消息代理商。Apache的工作集中使Kafka与Apache产品（包括Storm，HBase和Spark）一起工作，用于实时分析和呈现流数据。

Kafka从一开始就设计为分布式系统，因而易于扩展。它支持多订阅客户，并在故障期间自动平衡。

新版本的Kafka现在有四个核心API。生产API允许应用程序将流记录发布到一个或者多个Kafka主题。

Consumer API允许应用程序订阅一个或者多个主题，并解决为其生成的记录流。

Connector API可用于构建和运行可重用的生产者或者消费者，将Kafka主题连接到现有应用程序或者数据系统。

新的Streams API允许应用程序充任流解决器，消耗来自一个或者多个主题的输入流并产生到一个或者多个输出主题的输出流，有效地将输入流转换为输出流。