共計 2140 個字符，預計需要花費 6 分鐘才能閱讀完成。
這期內容當中丸趣 TV 小編將會給大家帶來有關 Kafka2.6.0 的性能提升示例分析，文章內容豐富且以專業的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。
近日 Kafka2.6 版本發布，距離 2.5.0 發布只過去了不到四個月的時間。
Kafka 2.6.0 包含許多重要的新功能。以下是一些重要更改的摘要：
默認情況下，已為 Java 11 或更高版本啟用 TLSv1.3
性能顯著提高，尤其是當代理具有大量分區時
擴展 Kafka Streams 的應用程序更便捷
Kafka Streams 支持更改時發出
新的 metrics 可提供更好的運營洞察力
配置為進行連接時，Kafka Connect 可以自動創建 Topic
改進了 Kafka Connect 中接收器連接器的錯誤報告選項
Kafka Connect 中的新過濾器和有條件地應用 SMT
“client.dns.lookup”配置的默認值現在為“use_all_dns_ips”。
將 Zookeeper 升級到 3.5.8
新功能
添加 KStream#repartition 操作
使 SSL 上下文 / 引擎配置可擴展
默認情況下啟用 TLSv1.3，并禁用某些較舊的協議
有條件地應用 SMT
向流指標添加任務級活動進程比率
重構主循環以一次處理一個任務的多個記錄
改善
增強了 TransformerSupplier / ProcessorSupplier
清理任務管理
將“onAssignment”流與“partitionsAssigned”任務創建合并
公開磁盤讀寫指標
允許消費者明確觸發重新平衡
將 gradle 更新為 6.0+
支持 Java 14
將默認版本切換到 Scala 2.13
- 改進“matchingAcls”的性能
控制臺生產者支持 client.id 的設置
升級指南：
如果要從 2.1.x 之前的版本升級，請參閱以下注釋，以了解用于存儲使用者偏移量的架構的更改。將 inter.broker.protocol.version 更改為最新版本后，將無法降級到 2.1 之前的版本。
對于滾動升級：
在所有代理上更新 server.properties 并添加以下屬性。CURRENT_KAFKA_VERSION 指的是您要升級的版本。CURRENT_MESSAGE_FORMAT_VERSION 是指當前使用的消息格式版本。如果以前覆蓋了消息格式版本，則應保留其當前值。或者，如果要從 0.11.0.x 之前的版本升級，則應將 CURRENT_MESSAGE_FORMAT_VERSION 設置為與 CURRENT_KAFKA_VERSION 相匹配。
inter.broker.protocol.version = CURRENT_KAFKA_VERSION（例如 2.5，2.4 等）
log.message.format.version = CURRENT_MESSAGE_FORMAT_VERSION
如果要從 0.11.0.x 或更高版本升級，并且尚未覆蓋消息格式，則只需要覆蓋代理間協議版本。
inter.broker.protocol.version = CURRENT_KAFKA_VERSION（例如 2.5，2.4 等）
一次升級一個代理：關閉代理，更新代碼，然后重新啟動。完成此操作后，代理將運行最新版本，并且您可以驗證集群的行為和性能是否符合預期。如果有任何問題，此時仍然可以降級。
驗證集群的行為和性能后，請通過編輯協議版本 inter.broker.protocol.version 并將其設置為來更改協議版本 2.6。
逐一重新啟動代理，以使新協議版本生效。代理開始使用最新的協議版本后，將無法再將群集降級到較舊的版本。
如果您已按照上述說明覆蓋了消息格式版本，則需要再次滾動重啟以將其升級到最新版本。一旦所有（或大多數）使用者都升級到 0.11.0 或更高版本，則在每個代理上將 log.message.format.version 更改為 2.6，然后逐一重新啟動它們。請注意，不再維護的較舊的 Scala 客戶端不支持 0.11 中引入的消息格式，為避免轉換成本必須使用較新的 Java 客戶端。
2.6.0 注意點
Kafka Streams 添加了一種新的處理模式（需要 Broker 2.5 或更高版本），該模式使用完全一次的保證提高了應用程序的可伸縮性。
缺省情況下，Java 11 或更高版本已啟用 TLSv1.3。如果客戶端和服務器均支持 TLSv1.3，則將協商該協議，否則將回退至 TLSv1.2。
缺省情況下，Java 11 或更高版本已啟用 TLSv1.3。如果客戶端和服務器均支持 TLSv1.3，則將協商該協議，否則將回退至 TLSv1.2。
NotLeaderForPartitionException 已棄用，并已替換為 NotLeaderOrFollowerException。如果代理不是副本，則獲取請求和僅用于領導者或跟隨者的其他請求將返回 NOT_LEADER_OR_FOLLOWER（6）而不是 REPLICA_NOT_AVAILABLE（9），以確保重新分配期間的此暫時錯誤由所有客戶端作為可重試的異常進行處理。
上述就是丸趣 TV 小編為大家分享的 Kafka2.6.0 的性能提升示例分析了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關知識，歡迎關注丸趣 TV 行業資訊頻道。
