Documentation ¶
Index ¶
Constants ¶
View Source
const CONSUME_TOTAL_MESSAGE_NUM int32 = 200
const CONSUME_ONE_PARTITION int = 10
View Source
const OFFSET_INIT string = "oldest"
Variables ¶
View Source
var Broker *kafka.Broker
记录每个topic分区的大小
Functions ¶
func GetKafkaBroker ¶
func GetKafkaBroker() ([]proto.MetadataRespBroker, int32)
get kafka broker list and controller id
func GetKafkaMsg ¶
get kafka topic msg
func GetTopicMsgNum ¶
get topic available msg count
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.