• 操作亮點(diǎn)

• 配置清理策略
• 測試消息大小
• 更多定制化屬性配置

操作流程

①、點(diǎn)擊新增Topic

②、填寫Topic的基本信息和配置

③、點(diǎn)擊確認(rèn)、創(chuàng)建成功！

操作亮點(diǎn)

簡單清晰的操作界面, 讓你能夠非?？焖俚膭?chuàng)建一個新的Topic；除了這個基本的功能外,你還可以看到在這里能夠針對每個Topic做更細(xì)粒度的定制化配置。

配置清理策略

默認(rèn)情況下, 普通Topic的清理策略為 delete? , 而 __consumer_offset?的默認(rèn)清理策略為compact

delete : 過期則直接把消息刪除

compact?: 消息緊縮, 如果消息key相同的話，那么value的值就是最近最新的一條。比如說__consumer_offset這個是記錄消費(fèi)組消費(fèi)的偏移量的信息。同一個消費(fèi)組消費(fèi)某個TopicPartition的時候,會把offset消息寫入到這個Topic中，每次寫入的Key是一樣的，但是Value不一樣。那獲取當(dāng)前消費(fèi)組消費(fèi)的Offset信息的時候，讀取的就是這個Key最新的一條。并且消息過期清理的話會把之前的刪掉。

測試消息大小

想設(shè)置這個Topic的指定大小, 但是卻又不知道消息大概有多大？

沒事, Know Streaming 為你提供了計算的窗口

在這里插入圖片描述

把你的消息體負(fù)責(zé)到這里面，就會自動展示給你占用的字節(jié)數(shù)，讓你在配置參數(shù)屬性的時候能夠有一個依據(jù)。

更多定制化屬性配置

這下面的配置,都只是針對的該Topic生效的,  并且這里配置的屬性 都是屬于動態(tài)配置。

關(guān)于什么是動態(tài)配置可以看：【kafka】kafka的動態(tài)配置管理使用和分析

可以點(diǎn)擊閱讀原文,直接訪問Know Streaming 體驗(yàn)環(huán)境

https://demo.knowstreaming.com/