這期內(nèi)容當(dāng)中小編將會(huì)給大家?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è)計(jì)，全程項(xiàng)目跟蹤，成都創(chuàng)新互聯(lián)公司專業(yè)和態(tài)度為您提供的服務(wù)

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

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

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

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

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

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

• 新的metrics可提供更好的運(yùn)營(yíng)洞察力

• 配置為進(jìn)行連接時(shí)，Kafka Connect可以自動(dòng)創(chuàng)建Topic

• 改進(jìn)了Kafka Connect中接收器連接器的錯(cuò)誤報(bào)告選項(xiàng)

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

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

• 將Zookeeper升級(jí)到3.5.8

新功能

• 添加KStream＃repartition操作

• 使SSL上下文/引擎配置可擴(kuò)展

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

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

• 向流指標(biāo)添加任務(wù)級(jí)活動(dòng)進(jìn)程比率

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

改善

• 增強(qiáng)了TransformerSupplier / ProcessorSupplier

• 清理任務(wù)管理

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

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

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

• 將gradle更新為6.0+

• 支持Java 14

• 將默認(rèn)版本切換到Scala 2.13

• -改進(jìn)“ matchingAcls”的性能

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

升級(jí)指南：

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

對(duì)于滾動(dòng)升級(jí)：

1. 在所有代理上更新server.properties并添加以下屬性。CURRENT_KAFKA_VERSION指的是您要升級(jí)的版本。CURRENT_MESSAGE_FORMAT_VERSION是指當(dāng)前使用的消息格式版本。如果以前覆蓋了消息格式版本，則應(yīng)保留其當(dāng)前值?；蛘?，如果要從0.11.0.x之前的版本升級(jí)，則應(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或更高版本升級(jí)，并且尚未覆蓋消息格式，則只需要覆蓋代理間協(xié)議版本。

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

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

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

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

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

2.6.0注意點(diǎn)

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。如果代理不是副本，則獲取請(qǐng)求和僅用于領(lǐng)導(dǎo)者或跟隨者的其他請(qǐng)求將返回NOT_LEADER_OR_FOLLOWER（6）而不是REPLICA_NOT_AVAILABLE（9），以確保重新分配期間的此暫時(shí)錯(cuò)誤由所有客戶端作為可重試的異常進(jìn)行處理。

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

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

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

廣告

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