1.下載安裝
下載地址：http://www.kafkatool.com/download.html

kafka Tool 的功能

2.本地windows下hosts配置kafka服務(wù)
注意:只有配置好了服務(wù)才能通過kafka tool 連通 kafka集群服務(wù)器!

cd C:\Windows\System32\drivers\etc

打開編輯hosts文件添加如下:
服務(wù)器地址 + 空格 + 別名

47.92.xxx.1x3     kafka-1
139.98.xxx.1x9    kafka-2
139.98.xxx.1x5    kafka-3

注意:這里的三個ip地址就是下面連接kafka tool配置中的Zookeeper Host,填寫一個就行!

3.安裝好連接kafka tool:
3.1 連接本地kafka:
前提是本地啟動了kafka服務(wù),

1.win + r  --> cmd 輸入:  zkServer        打開zookeeper
2.開啟kafka:      .\bin\windows\kafka-server-start.bat .\config\server.properties
3.消費(fèi)者:         .\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test2020 --from-beginning
4.生產(chǎn)者:         .\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
5. 關(guān)閉zookeeper: 進(jìn)入文件夾bin,   .\zkServer.sh stop
6. 關(guān)閉 kafka: 進(jìn)去kafka文件  bin\kafka-server-stop.sh

連接配置如下:

注意:
剛連接上的時候是一個小紅點(diǎn):表示未連接狀態(tài)

右鍵點(diǎn)擊連接

注意:在使用Kafka Tool工具時，查看Topics多了一個topic，就隨手刪除了。然后問題來了
本地啟動kafka報錯:

Kafka報錯: ERROR Shutdown broker because all log dirs in ... have failed

Kafka服務(wù)開始報錯：
ERROR Shutdown broker because all log dirs in E:\kafka\kafka_2.11-2.4.0\log have failed (kafka.log.LogManager)
解決:
去報錯提示的目錄下刪除log里topic日志，重啟kafka還是報錯。原來刪除kafka的log目錄還不能解決此問題，還得刪除zookeeper里zoo.cfg里配置的dataDir目錄。
注意：如果是重要數(shù)據(jù)，一定要備份?。?！

原文鏈接：https://blog.csdn.net/szxiaohe/article/details/103639127

3.2 連接遠(yuǎn)程kafka 集群服務(wù)器
點(diǎn)擊 file --> Add Cluster 進(jìn)行配置

然后:

4.創(chuàng)建和刪除topic:

4.1創(chuàng)建topic

5. 基本使用
   kafka環(huán)境搭建請參考：CentOS7.5搭建Kafka2.11-1.1.0集群
   配置以字符串的形式顯示kafka消息體

或者通過如下界面配置

注釋：更改完Content Types，要點(diǎn)擊Update和Refresh按鈕

再次查看kafka的數(shù)據(jù)：

6.特色功能:
Kafka工具中的瀏覽器樹允許您通過單擊幾下鼠標(biāo)來查看和導(dǎo)航Apache Kafka?集群中的對象-代理，主題，分區(qū)，使用者。與Kafka群集的連接將保持不變，因此您無需每次都記住或輸入它們。無論有多少群集，您都可以快速查看有關(guān)所有群集的信息。

查看訊息

您可以在主題的分區(qū)中快速查看消息及其鍵。您可以選擇一次查看多少條消息以及從中讀取消息的偏移量。您可以查看最早或最新的消息，也可以指定從中開始讀取消息的起始偏移量。默認(rèn)情況下，Kafka工具將以十六進(jìn)制格式顯示您的消息和密鑰。但是，如果您的消息是UTF-8編碼的字符串，則Kafka工具可以顯示實(shí)際的字符串，而不是常規(guī)的十六進(jìn)制格式。

以JSON / XML格式查看文本數(shù)據(jù)

如果基于字符串的數(shù)據(jù)為JSON或XML格式，則可以在分區(qū)下“數(shù)據(jù)”選項卡的詳細(xì)信息面板中以漂亮打印的形式查看數(shù)據(jù)。

查看消費(fèi)者抵銷

瀏覽器樹允許您快速查看Kafka使用者的所有偏移量。該列表將同時顯示分區(qū)的開始/結(jié)束偏移以及每個分區(qū)內(nèi)使用者的偏移。

您還可以查看Apache Storm的Kafka噴口存儲的偏移量。閱讀更多

保存?zhèn)€人信息

您可以使用分區(qū)的“數(shù)據(jù)”選項卡的詳細(xì)信息面板中的“保存”按鈕將單個消息保存到硬盤驅(qū)動器上的文件中。該文件將按原樣包含消息的字節(jié)。您也可以使用相同的機(jī)制保存消息的密鑰。

參考轉(zhuǎn)載 https://www.cnblogs.com/frankdeng/p/9452982.html