千呼萬喚始出來，經過7年的發展與完善，Apache Kafka 1.0.0正式發布！在筆者看來，比起1.0.0引入的新功能，此版本最大的意義在于標識Kafka各種組件功能的穩定性。不過我們還是來看下1.0.0引入的一些新功能：

• Kafka Streams API的優化：增加了一些全新的操作算子(operator)，如cogroup等。另外print和writeAsText方法的改進更加方便了對Streams程序的調試
• JMX監控指標的完善：引入了很多集群健康度檢查指標，同時對Kafka Connect監控體系做了較大程度的補足
• 正式支持Java 9：Java 9優化TLS和CRC32的性能(JEP 249以及引入了java.util.zip.CRC32C)，因此在Java 9上啟用Kafka安全后可以更快地進行數據加密以及checksum計算與校驗
• 優化SASL認證錯誤的處理：之前某些SASL認證異常沒有清晰顯式地與其他異常區分開來。1.0.0版本更加“優雅”地處理這些異常，參見KAFKA-4764
• 強化對JBOD磁盤崩潰的處理：之前JBOD下Kafka無法容忍磁盤崩潰，會直接導致broker宕機。該新功能正式支持JBOD錯誤處理——筆者以為這是普通Kafka用戶(沒有使用Kafka Streams)最期待的1.0新功能了
• 冪等producer的優化：之前為了保證消息的順序性，在啟用冪等producer之后強制設置max.in.flight.requests.per.connection=1，因而影響producer的TPS。KAFKA-5949引入了新的算法使得在保持冪等和EOS的同時還能提升該參數上限到5，一定程度上緩解了對TPS的傷害

比起Apache Flink火箭速度的版本演進，Kafka 1.0發布的確有些慢了，不過我們總算是等到了這個正式版本。接下來問題來了，Confluent會把KSQL捐獻給Apache社區嗎：-）

轉載于:https://www.cnblogs.com/huxi2b/p/7770706.html

總結

以上是生活随笔為你收集整理的Apache Kafka 1.0.0正式发布！的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。