前言
tail
涉及的golang库和可视化工具:
go-inisaramatail
go-inisaramatail
可视化工具:
offsetexplorer
工作的流程
saramakafkatailtail
环境准备
zookeeperkafkasaramaoffsetexplorer
代码分层
tailsarama
main函数为程序入口
关键的代码
main.go
tailsrama
kafka.go
有3个方法 :
InitKafkaListenerDestruct
tail.go
主要包括了两个方法:
TailInittailListenerListenerkafka