kafka

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

type ConsumerConfig struct {
	Name              string   `yaml:"name"`
	Addrs             []string `yaml:"addrs"`
	ConsumerGroup     string   `yaml:"consumer_group"`
	Topics            []string `yaml:"topics"`
	OffsetsInitial    int64    `yaml:"offsets_initial"`
	OffsetsAutoCommit bool     `yaml:"offsets_auto_commit"`
}

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

type ProducerConfig struct {
	Name  string   `yaml:"name"`
	Addrs []string `yaml:"addrs"`
}