這期內(nèi)容當(dāng)中小編將會給大家?guī)碛嘘P(guān)Kafka2.6.0的性能提升示例分析，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

成都創(chuàng)新互聯(lián)公司專注于永勝企業(yè)網(wǎng)站建設(shè),自適應(yīng)網(wǎng)站建設(shè),商城網(wǎng)站建設(shè)。永勝網(wǎng)站建設(shè)公司,為永勝等地區(qū)提供建站服務(wù)。全流程定制網(wǎng)站開發(fā)，專業(yè)設(shè)計，全程項目跟蹤，成都創(chuàng)新互聯(lián)公司專業(yè)和態(tài)度為您提供的服務(wù)

近日Kafka2.6版本發(fā)布，距離2.5.0發(fā)布只過去了不到四個月的時間。

Kafka 2.6.0包含許多重要的新功能。以下是一些重要更改的摘要：

• 默認情況下，已為Java 11或更高版本啟用TLSv1.3

• 性能顯著提高，尤其是當(dāng)代理具有大量分區(qū)時

• 擴展Kafka Streams的應(yīng)用程序更便捷

• Kafka Streams支持更改時發(fā)出

• 新的metrics可提供更好的運營洞察力

• 配置為進行連接時，Kafka Connect可以自動創(chuàng)建Topic

• 改進了Kafka Connect中接收器連接器的錯誤報告選項

• Kafka Connect中的新過濾器和有條件地應(yīng)用SMT

• “ client.DNS.lookup”配置的默認值現(xiàn)在為“ use_all_dns_ips”。

• 將Zookeeper升級到3.5.8

新功能

• 添加KStream＃repartition操作

• 使SSL上下文/引擎配置可擴展

• 默認情況下啟用TLSv1.3，并禁用某些較舊的協(xié)議

• 有條件地應(yīng)用SMT

• 向流指標(biāo)添加任務(wù)級活動進程比率

• 重構(gòu)主循環(huán)以一次處理一個任務(wù)的多個記錄

改善

• 增強了TransformerSupplier / ProcessorSupplier

• 清理任務(wù)管理

• 將“ onAssignment”流與“ partitionsAssigned”任務(wù)創(chuàng)建合并

• 公開磁盤讀寫指標(biāo)

• 允許消費者明確觸發(fā)重新平衡

• 將gradle更新為6.0+

• 支持Java 14

• 將默認版本切換到Scala 2.13

• -改進“ matchingAcls”的性能

• 控制臺生產(chǎn)者支持client.id的設(shè)置

升級指南：

如果要從2.1.x之前的版本升級，請參閱以下注釋，以了解用于存儲使用者偏移量的架構(gòu)的更改。將inter.broker.protocol.version更改為最新版本后，將無法降級到2.1之前的版本。

對于滾動升級：

1. 在所有代理上更新server.properties并添加以下屬性。CURRENT_KAFKA_VERSION指的是您要升級的版本。CURRENT_MESSAGE_FORMAT_VERSION是指當(dāng)前使用的消息格式版本。如果以前覆蓋了消息格式版本，則應(yīng)保留其當(dāng)前值。或者，如果要從0.11.0.x之前的版本升級，則應(yīng)將CURRENT_MESSAGE_FORMAT_VERSION設(shè)置為與CURRENT_KAFKA_VERSION相匹配。

• inter.broker.protocol.version = CURRENT_KAFKA_VERSION（例如2.5，2.4等）

• log.message.format.version = CURRENT_MESSAGE_FORMAT_VERSION

1. 如果要從0.11.0.x或更高版本升級，并且尚未覆蓋消息格式，則只需要覆蓋代理間協(xié)議版本。

• inter.broker.protocol.version = CURRENT_KAFKA_VERSION（例如2.5，2.4等）

2. 一次升級一個代理：關(guān)閉代理，更新代碼，然后重新啟動。完成此操作后，代理將運行最新版本，并且您可以驗證集群的行為和性能是否符合預(yù)期。如果有任何問題，此時仍然可以降級。

3. 驗證集群的行為和性能后，請通過編輯協(xié)議版本inter.broker.protocol.version并將其設(shè)置為來更改協(xié)議版本 2.6。

4. 逐一重新啟動代理，以使新協(xié)議版本生效。代理開始使用最新的協(xié)議版本后，將無法再將群集降級到較舊的版本。

5. 如果您已按照上述說明覆蓋了消息格式版本，則需要再次滾動重啟以將其升級到最新版本。一旦所有（或大多數(shù)）使用者都升級到0.11.0或更高版本，則在每個代理上將log.message.format.version更改為2.6，然后逐一重新啟動它們。請注意，不再維護的較舊的Scala客戶端不支持0.11中引入的消息格式，為避免轉(zhuǎn)換成本必須使用較新的Java客戶端。

2.6.0注意點

Kafka Streams添加了一種新的處理模式（需要Broker 2.5或更高版本），該模式使用完全一次的保證提高了應(yīng)用程序的可伸縮性。

缺省情況下，Java 11或更高版本已啟用TLSv1.3。如果客戶端和服務(wù)器均支持TLSv1.3，則將協(xié)商該協(xié)議，否則將回退至TLSv1.2。

缺省情況下，Java 11或更高版本已啟用TLSv1.3。如果客戶端和服務(wù)器均支持TLSv1.3，則將協(xié)商該協(xié)議，否則將回退至TLSv1.2。

NotLeaderForPartitionException已棄用，并已替換為NotLeaderOrFollowerException。如果代理不是副本，則獲取請求和僅用于領(lǐng)導(dǎo)者或跟隨者的其他請求將返回NOT_LEADER_OR_FOLLOWER（6）而不是REPLICA_NOT_AVAILABLE（9），以確保重新分配期間的此暫時錯誤由所有客戶端作為可重試的異常進行處理。

上述就是小編為大家分享的Kafka2.6.0的性能提升示例分析了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關(guān)知識，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

分享文章：Kafka2.6.0的性能提升示例分析
文章來源：http://www.chinadenli.net/article36/igjesg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站營銷、云服務(wù)器、品牌網(wǎng)站制作、企業(yè)網(wǎng)站制作、定制網(wǎng)站、建站公司

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)