如何快速優(yōu)雅的用Know Streaming創(chuàng)建Topic
- 操作亮點
- 配置清理策略
- 測試消息大小
- 更多定制化屬性配置
操作流程
①、點擊新增Topic
②、填寫Topic的基本信息和配置
③、點擊確認、創(chuàng)建成功!
操作亮點
簡單清晰的操作界面, 讓你能夠非常快速的創(chuàng)建一個新的Topic;除了這個基本的功能外,你還可以看到在這里能夠針對每個Topic做更細粒度的定制化配置。
配置清理策略
默認情況下, 普通Topic的清理策略為 delete? , 而 __consumer_offset?的默認清理策略為compact
delete : 過期則直接把消息刪除
compact?: 消息緊縮, 如果消息key相同的話,那么value的值就是最近最新的一條。比如說__consumer_offset這個是記錄消費組消費的偏移量的信息。同一個消費組消費某個TopicPartition的時候,會把offset消息寫入到這個Topic中,每次寫入的Key是一樣的,但是Value不一樣。那獲取當前消費組消費的Offset信息的時候,讀取的就是這個Key最新的一條。并且消息過期清理的話會把之前的刪掉。
測試消息大小
想設(shè)置這個Topic的指定大小, 但是卻又不知道消息大概有多大?
沒事, Know Streaming 為你提供了計算的窗口
在這里插入圖片描述
把你的消息體負責(zé)到這里面,就會自動展示給你占用的字節(jié)數(shù),讓你在配置參數(shù)屬性的時候能夠有一個依據(jù)。
更多定制化屬性配置
這下面的配置,都只是針對的該Topic生效的, 并且這里配置的屬性 都是屬于動態(tài)配置。
關(guān)于什么是動態(tài)配置可以看:【kafka】kafka的動態(tài)配置管理使用和分析
可以點擊閱讀原文,直接訪問Know Streaming 體驗環(huán)境
https://demo.knowstreaming.com/