package
0.0.0-20250115014547-cb81800ed961
Repository: https://github.com/opensourceways/message-collect.git
Documentation: pkg.go.dev

# Functions

No description provided by the author
Init initializes the Kafka agent with the specified configuration, logger, and removeCfg flag.

# Variables

Exit is an exported variable that provides the exit function for the Kafka package.

# Structs

Config represents the configuration for Kafka.
No description provided by the author

# Interfaces

Handler.