操作場景
您可以查看指(zhi)定Topic不同(tong)分區(qu)的偏移量、消息大小、創建時(shi)間以及消息正文。
操作步驟
步驟 1 登錄管理控制臺。
步驟 2 在管理控制臺右上角單擊
,選擇區域。
說明請選擇Kafka實例所在的(de)區域。
步驟 3 在管理控制臺左上角單擊
,選擇“企業中間(jian)件”-“分布式消(xiao)息服務”-“Kafka專享版”,進入分布式消(xiao)息服務Kafka專享版頁面。
步(bu)驟 4 單擊Kafka實(shi)例(li)名稱,進入實(shi)例(li)詳情頁面。
步驟 5 選擇(ze)“消息查(cha)詢(xun)”頁簽(qian),在消息頁簽(qian)頁面(mian),設置(zhi)查(cha)詢(xun)的Topic名稱、分區(qu)以及查(cha)詢(xun)方式(shi)。
如果未(wei)設置具體分區,查詢結果顯示Topic所有分區的消(xiao)息。
查(cha)詢方(fang)式支持以下兩種方(fang)式:
- 按創建時間查詢:即按生產該消息的時間。
- 按偏移量查詢:即記錄消息的位置。
說明當Topic中的數據量比較大時,單副本Topic查詢消息可能會報“內部服務錯誤”,建議根據數據量適當減小查詢時間范圍。
步驟 6 單擊“搜索”,查詢(xun)消(xiao)息。
查詢結果如下:
圖(tu) 查詢(xun)Topic消息


消息的(de)參(can)數(shu)說明如(ru)下(xia):
- Topic名稱:消息所在的Topic名稱。
- 分區:消息所在的分區。
- 偏移量:消息在分區中的位置。
- 消息大小:消息存入磁盤的大小,單位為B。
- 創建時間:消息的創建時間。創建時間由生產客戶端在生產消息時通過CreateTime指定的,如果生產消息時沒有設置此參數,創建時間會默認為1970。
步驟 7 單(dan)擊“查(cha)(cha)看消(xiao)息(xi)(xi)正(zheng)文(wen)(wen)”,彈出“查(cha)(cha)看消(xiao)息(xi)(xi)正(zheng)文(wen)(wen)”對話框(kuang),查(cha)(cha)看消(xiao)息(xi)(xi)的(de)內(nei)容(rong),包(bao)括(kuo)Topic名稱、分(fen)區、偏移量、創建(jian)時(shi)間和消(xiao)息(xi)(xi)正(zheng)文(wen)(wen)。
步(bu)驟 8 (可選(xuan))如果需要恢復(fu)默(mo)認設置,單擊“重置”。