做这个项目是为了学习golang 和 kafka。仿照kafdrop的部分功能实现了go的版本,实现功能:
1.查看broker地址和controller。
2.查看topic列表,每个topic分区个数,每个topic可消费消息个数。
3.查看topic下前200个消息内容,消息offset,消息所在分区。
拷贝beego的样例代码,在此基础开发
http://v3.bootcss.com/ https://jquery.com/download/
go build -o kafdrop.exe main.go 在cmd窗口执行kafdrop.exe 访问http://127.0.0.1:8090