//
pkg.gl
Category
github.com/xiaof-github/kafdrop-go
kafgo
package
0.2.3
Repository:
https://github.com/xiaof-github/kafdrop-go.git
Documentation:
pkg.go.dev
Overview
Versions
1
Dependencies
3
Dependents
2
Files
200 SLOC
#
Functions
GetKafkaBroker
get kafka broker list and controller id.
GetKafkaMsg
get kafka topic msg.
GetKafkaTopic
get kafka topic list.
GetTopicMsgNum
get topic available msg count.
#
Constants
CONSUME_TOTAL_MESSAGE_NUM
const CONSUME_ONE_PARTITION int = 10.
OFFSET_INIT
No description provided by the author
#
Variables
Broker
No description provided by the author
TopicPartition
记录每个topic分区的大小.