感謝點(diǎn)贊和關(guān)注 ,每天進(jìn)步一點(diǎn)點(diǎn)!加油!
目錄
一、概述
二、環(huán)境信息
三、安裝和使用
3.1 下載Offset Explorer 和安裝
3.2 軟件配置
3.2.1Properties
3.2.2Properties
3.2.3Advanced
3.2.4 JAAS config
3.2.5修改配置文件
3.3 基本使用
3.3.1查看topic分區(qū)列表及分區(qū)leader位置信息
3.3.2查看數(shù)據(jù)
一、概述
Offset Explorer(以前稱為Kafka Tool)是一個(gè)用于管理和使Apache Kafka ?集群的GUI應(yīng)用程序。它提供了一個(gè)直觀的UI,允許人們快速查看Kafka集群中的對(duì)象以及存儲(chǔ)在集群主題中的消息。它包含面向開發(fā)人員和管理員的功能。
一些關(guān)鍵功能包括:
- 快速查看所有Kafka集群,包括它們的代理、主題和消費(fèi)者
- 查看分區(qū)中的消息內(nèi)容并添加新消息
- 查看消費(fèi)者的偏移量,包括Apache Storm Kafka spout消費(fèi)者
- 以漂亮的打印格式顯示JSON、XML和Avro消息
- 添加和刪除主題以及其他管理功能
- 將分區(qū)中的單個(gè)消息保存到本地硬盤驅(qū)動(dòng)器
- 編寫您自己的插件,允許您查看自定義數(shù)據(jù)格式
- Offset Explorer在Windows、Linux和Mac OS上運(yùn)行
二、環(huán)境信息
系統(tǒng)環(huán)境:windows 10
Offset explorer版本:2.2
Kafka版本:Kafka2.0.0

三、安裝和使用
3.1 下載Offset Explorer 和安裝
下載地址:Offset Explorer

下載到本地的 .exe文件

Next

accept Next

安裝路徑 ,Next

Next

Finish

3.2 軟件配置
3.2.1Properties
下載安裝完畢,進(jìn)行新增連接,啟動(dòng)offsetexplorer.exe,在Add Cluster窗口Properties 選項(xiàng)下填寫Cluster name 和 kafka Cluster Version等參數(shù)信息。
- 集群名稱:可隨意填寫;
- 集群版本:需要確認(rèn),不同版本之間差異大;
- zookeeper所在的服務(wù)器ip地址:
- 端口;

3.2.2Properties
配置安全項(xiàng),根據(jù)自己環(huán)境選擇選擇,我的環(huán)境是SASL_PLAINTEXT,下面選擇SASL_PLAINTEXT即可。
SASL_PLAINTEXT:使用SASL框架來做認(rèn)證和數(shù)據(jù)加密,使用明文傳輸數(shù)據(jù)
SASL_SSL:使用SASL框架來做認(rèn)證和數(shù)據(jù)加密,使用SSL加密傳輸數(shù)據(jù)


3.2.3Advanced
Bootstrap servers:配置自己的kafka的broker地址
SASL Mechanism: 填寫GSSAPI(這里表示SASL的實(shí)現(xiàn),GSSAPI是一套接口,現(xiàn)在只有Kerberos v5實(shí)現(xiàn)了這個(gè)接口;這里實(shí)際就是指的是Kerberos)


3.2.4 JAAS config
如果不是使用GSSAPI可以參考官網(wǎng);否則有兩種方法,第一種命令行啟動(dòng)添加配置,第二種修改配置文件;
我們 JAAS 也可以不用配置 直接用參數(shù) 添加到 offsetexplorer.exe 啟動(dòng)命令后面。
com.sun.security.auth.module.Krb5LoginModule required
useKeyTab=true
storeKey=true
client=true
serviceName="kafka"
keyTab="D:/work/winner/kerberos/kafka/kafka.service.keytab"
principal="kafka/hdp103@WINNER.COM";

update 配置后 cd 到 offsetexplorer 的安裝目錄,添加啟動(dòng)參數(shù) krb5.conf。
offsetexplorer.exe -J-Djava.security.krb5.conf=D:/work/winner/kerberos/kafka/krb5.conf
JAAS 中沒有配置可以 在啟動(dòng)參數(shù)中添加 JAAS.conf 路徑。
offsetexplorer.exe -J-Djava.security.auth.login.config=D:/work/winner/kerberos/kafka/kafka_client_winner_jaas.conf -J-Djava.security.krb5.conf=D:/work/winner/kerberos/kafka/kafka.service.keytab -J-Djava.security.krb5.conf=D:/work/winner/kerberos/kafka/krb5.conf
3.2.5修改配置文件
找到offset explorer安裝目錄,然后打開offsetexplorer.vmoptions文件,在末尾添加如下信息(保存關(guān)閉,以后每次啟動(dòng)都會(huì)生效,如果訪問其他KDC集群,請(qǐng)修改配置然后重啟):

3.3 基本使用
3.3.1查看topic分區(qū)列表及分區(qū)leader位置信息

3.3.2查看數(shù)據(jù)
kafka成功連接之后可以看到該kafka的Topics信息,如果是集群kafka,可以看到集群下所有節(jié)點(diǎn)的信息。
- 打開某一個(gè)topic,點(diǎn)擊Data查看數(shù)據(jù),一開始是沒有數(shù)據(jù)的;
- 選擇消費(fèi)方式,是從開始消費(fèi)還是從最新開始消費(fèi);
- 選消費(fèi)方式后,點(diǎn)擊左上角的“綠色三角符號(hào)” 播放按鈕才會(huì)展示數(shù)據(jù),可設(shè)置查詢的條數(shù)。
列表分別展示:消息所屬的partition(分區(qū)) , offset(偏移量), message(消息數(shù)據(jù)),timestamp(數(shù)據(jù)生成時(shí)間戳),
選中具體數(shù)據(jù)后,查看下方面板

————————————————
參考鏈接
原文鏈接:Offset explorer連接Kerberos認(rèn)證的Kafka_offset連接kafka_過悟的博客-CSDN博客
原文鏈接:Kafka消息可視化工具-Offset Explorer使用_kafka消息查看工具_(dá)水w的博客-CSDN博客文章來源:http://www.zghlxwxcb.cn/news/detail-794345.html
原文鏈接:Kafka的終極UI工具丨Offset Explorer功能簡(jiǎn)介_offsetexplorer_51component技術(shù)交流的博客-CSDN博客文章來源地址http://www.zghlxwxcb.cn/news/detail-794345.html
感謝點(diǎn)贊和關(guān)注!
到了這里,關(guān)于【可視化工具】Kafka-Offset Explorer使用的文章就介紹完了。如果您還想了解更多內(nèi)容,請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!