kfk

type ConsumErr struct {
	Err error
	Msg kafka.Message
}

type Consumer struct {
	// contains filtered or unexported fields
}

type Handler func(kafka.Message) error

type KfkConsumCfg struct {
	Brokers     []string `yaml:"brokers"`
	GroupTopics []string `yaml:"group_topics"`
	GroupID     string   `yaml:"group_id"`
	BatchSize   int      `yaml:"batch_size"`
	MinBytes    int      `yaml:"min_bytes"`
	MaxBytes    int      `yaml:"max_bytes"`
	Sasl        SaslCfg  `yaml:"sasl"`
}

type KfkProducerCfg struct {
	Brokers                []string `yaml:"brokers"`
	Topic                  string   `yaml:"topic"`
	Acks                   int      `yaml:"acks"`
	Async                  bool     `yaml:"async"`
	Timeout                int      `yaml:"timeout"`
	Sasl                   SaslCfg  `yaml:"sasl"`
	AllowAutoTopicCreation bool     `yaml:"allow_auto_topic_creation"`
	BatchSize              int      `yaml:"batch_size"`
	BatchBytes             int      `yaml:"batch_bytes"`
}

type Producer struct {
	// contains filtered or unexported fields
}

type SaslCfg struct {
	Enabled  bool   `yaml:"enabled"` //密码开关
	Algo     string `yaml:"algo"`    // 身份验证加密机制
	Username string `yaml:"username"`
	Password string `yaml:"password"`
}