rkafka

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

type ConsumerConf struct {
	ClientID string `yaml:"clientID"`
	GroupID  string `yaml:"groupID"`
	Server   string `yaml:"server"`
	Topic    string `yaml:"topic"`
	Limit    int    `yaml:"limit"`
}

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

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

type ManagerConf struct {
	Consumers map[string]ConsumerConf
}

type OnError func(err error, ctx context.Context)

type OnProcess func(msg *kafka.Message, ctx context.Context)