kq

type Conf struct {
	// kafka broker addresses
	Brokers []string `json:"brokers" yaml:"brokers"`

	// topic name
	Topic string `json:"topic" yaml:"topic"`

	// consumer group name
	Group string `json:"group" yaml:"group"`

	// whether to create topic if topic is missing, default false
	AutoCreateTopic *bool `json:"auto_create_topic" yaml:"auto_create_topic"`

	// the count of the topics to create, default 4
	Partitions int `json:"topic_partitions" yaml:"topic_partitions"`

	// the replication count of each topic partition, default 3
	Replications int `json:"replications" yaml:"replications"`

	// the count of workers that consumes synchronously, default is the count of topic partition
	Processors int `json:"processors" yaml:"processors"`

	// default 10K
	MinBytes int `json:"min_bytes" yaml:"min_bytes"`

	// default 10M
	MaxBytes int `json:"max_bytes" yaml:"max_bytes"`

	// certificate file path for connecting to kafka
	CaFile string `json:"ca_file" yaml:"ca_file"`

	// username for connecting to kafka
	Username string `json:"username" yaml:"username"`

	// password for connecting to kafka
	Password string `json:"password" yaml:"password"`
}

type ConsumeHandler func(ctx context.Context, topic string, msg *model.Msg) error

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

type ConsumerOption func(consumer *Consumer)

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

type ProducerOption func(producer *Producer)