Kafka Tool是一個用于管理和使用Apache Kafka?集群的GUI應用程序。 Kafka Tool提供了一個較為直觀的UI可讓用戶快速查看Kafka集群中的對象以及存儲在topic中的消息，提供了一些專門面向開發人員和管理員的功能，主要特性包括：
- 快速查看所有Kafka集群信息，包括其brokers, topics and consumers
- 查看分區中的消息內容并支持添加新消息
- 查看消費者偏移量，支持查看Apache Storm Kafka Spout消費者偏移量
- 以pretty-printed 格式顯示JSON和XML消息
- 添加和刪除topic以及其他管理功能
- 將單個消息從指定分區保存到本地硬盤驅動器
- 支持用戶編寫自己的插件以查看自定義數據格式
- 支持在Windows，Linux和Mac OS上運行
Kafka工具僅供個人使用免費。 未經購買許可證，不得將其用于任何非個人用途，包括商業，教育和非營利性工作。 在下載Kafka Tool后的30天內，出于評估目的非個人是允許使用的，在此之后，用戶必須購買有效的許可證或刪除該軟件。
下載安裝
下載地址鏈接https://www.kafkatool.com/download.html
配置
第一次打開軟件時Kafka Tool會以彈窗的形式提示進行Kafka Cluster配置，需要輸入Zookeeper或者Broker地址以找到相應集群。
當然除了基本屬性設置外還支持安全性設置、高級設置及JAAS設置等。
將公司Kafka集群的Cluster name, Kafka Cluster Version, Zookeeper Host等配置信息按照要求填寫到相關設置項中.
使用
預覽
Kafka Tool提供了集群Brokers，Topics，Consumers信息預覽功能，查看指定Topic下消息時支持關鍵詞過濾等。
選中Topic，進入topic設置詳情頁，從頁面中可以設置從Oldest還是Newest位置讀取消息，同時可以設置讀取數據的格式（String或者ByteArray）。由于測試Topic中數據是JSON格式，演示中將key和value都設置為String格式，設置完成后如果update沒有變為灰色需要手動點擊update更新配置。
可以通過”詳情展示“ 按鈕來查看詳情，也可以選擇讀取位置。
在詳情展示頁面，支持修改查看消息的格式類型，在Text、Hex、JSON與XML之間任意切換
分區管理，新增和刪除
在 ”topic分區管理“中，點擊 ” “ 按鈕，設置 ”topic“ 信息(名字,分區數,副本數)，即可創建topic。
有創建當然也會有刪除啦，在topic分區管理中，選擇需要刪除的分區，點擊 ”ד 按鈕，彈出來的提示框中選擇是，即可刪除topic。
刪除操作一定要慎重!請仔細確認!!!
刪除操作一定要慎重!請仔細確認!!!
刪除操作一定要慎重!請仔細確認!!!
為分區增加消息
在topic分區管理中，選擇某個分區，可以為分區增加消息。點擊 ”Data“ 下面的 ” “ 按鈕，彈出框選擇 ”Add Multiple Message“，設置消息配置選項，在 ”Data“ 文本框按格式輸入要添加消息，點擊確定即可添加消息。
使用Kafka Tool查看和管理Consumer
界面左側點擊Consumers可以看到該集群的所有消費者組，在下面列出來的消費者組中,隨便點擊一個，右側會出現包含Properties和Offsets選項的界面。。
Properties包含如下內容:消費者組(組名)Id,消費者類型,偏移量存儲位置。
Offsets包含如下信息:刷新、打印、編輯功能，可以獲取到消費者組消費的topic信息,分區偏移量信息,獲取消費端的偏移量,積壓的偏移量,以及偏移量最后提交時間等。
當然這里也可以進行編輯，選擇要進行編輯的消費者組，雙擊編輯按鈕， 選擇設置偏移量方式(從起始位置消費,從截止位置消費,或者從指定的偏移量開始消費)
，點擊update完成設置。
以這樣的方式，跳過偏移數據，從而達到消費端的偏移量和topic的截止消費量一致(不等的原因是,topic一直有數據推送)，，以提高消費端性能,減少資源占用。
原文 https://www.studytime.xin/article/kafka-tool.html
版權聲明：本文內容由互聯網用戶自發貢獻，該文觀點僅代表作者本人。本站僅提供信息存儲空間服務，不擁有所有權，不承擔相關法律責任。如發現本站有涉嫌抄襲侵權/違法違規的內容， 請發送郵件至 舉報，一經查實，本站將立刻刪除。