Kafka從首次發(fā)布之日起，已經(jīng)走過了七個(gè)年頭。從最開始的大規(guī)模消息系統(tǒng)，發(fā)展成為功能完善的分布式流式處理平臺(tái)，用于發(fā)布和訂閱、存儲(chǔ)及實(shí)時(shí)地處理大規(guī)模流數(shù)據(jù)。來自世界各地的數(shù)千家公司在使用Kafka，包括三分之一的500強(qiáng)公司。Kafka以穩(wěn)健的步伐向前邁進(jìn)，首先加入了復(fù)制功能和無邊界的鍵值數(shù)據(jù)存儲(chǔ)，接著推出了用于集成外部存儲(chǔ)系統(tǒng)的Connect API，后又推出了為實(shí)時(shí)應(yīng)用和事件驅(qū)動(dòng)應(yīng)用提供原生流式處理能力的Streams API，并于今年春季開始支持僅一次處理語義。如此廣泛的應(yīng)用和完備的功能以及如此悠久的歷史，無一不在說明Kafka已經(jīng)成為一款穩(wěn)定的企業(yè)級(jí)產(chǎn)品。而更為激動(dòng)人心的是，Kafka現(xiàn)在正式迎來了1.0.0版本！

Kafka 1.0.0發(fā)布的主要內(nèi)容如下。

0.10.0版本里開始引入的Streams API在1.0.0版本里繼續(xù)演進(jìn)，改進(jìn)了builder API（KIP-120），新增了用于查看運(yùn)行時(shí)活躍任務(wù)的API（KIP-130）和用于聚合分區(qū)的cogroup
API（KIP-150）。增強(qiáng)的print()和writeAsText()方法讓調(diào)試變得更容易（KIP-160）。其他更多信息可以參考Streams文檔。改進(jìn)了Connect的度量指標(biāo)（KIP-196），新增了大量用于健康監(jiān)測(cè)的度量指標(biāo)（KIP-188），并提供了集群的GloabalTopicCount和GlobalPartitionCount度量指標(biāo)（KIP-168）。支持Java 9，實(shí)現(xiàn)更快的TLS和CRC32C，加快了加密速度，降低了計(jì)算開銷。調(diào)整了SASL認(rèn)證模塊的錯(cuò)誤處理邏輯（KIP-152），原先的認(rèn)證錯(cuò)誤信息現(xiàn)在被清晰地記錄到日志當(dāng)中。更好地支持磁盤容錯(cuò)（KIP-112），更優(yōu)雅地處理磁盤錯(cuò)誤，單個(gè)JBOD上的磁盤錯(cuò)誤不會(huì)導(dǎo)致整個(gè)集群崩潰。0.11.0版本中引入的冪等性生產(chǎn)者需要將max.in.flight.requests.per.connection參數(shù)設(shè)置為1，這對(duì)吞吐量造成了一定的限制。而在1.0.0版本里，這個(gè)參數(shù)最大可以被設(shè)置為5（KAFKA-5949），極大提升了吞吐量范圍。

關(guān)于新版本更多的變化可以查看發(fā)布說明，也可以下載源代碼和二進(jìn)制包（Scala 2.11、Scala 2.12）。