前言

tail

涉及的golang库和可视化工具:

go-inisaramatail
go-inisaramatail

可视化工具:

offsetexplorer

工作的流程

saramakafkatailtail

main.png

环境准备

zookeeperkafkasaramaoffsetexplorer

代码分层

tailsarama

main函数为程序入口

 

pro-dir.png

关键的代码

main.go

tailsrama

kafka.go

有3个方法 :

InitKafkaListenerDestruct

tail.go

主要包括了两个方法:

TailInittailListenerListenerkafka