config

type Config struct {
	Brokers           []string `config:"brokers"`
	Topics            []string `config:"topics"`
	ClientID          string   `config:"client_id"`
	Group             string   `config:"group"`
	Offset            string   `config:"offset"`
	Codec             string   `config:"codec"`
	PublishMode       string   `config:"publish_mode"`
	ChannelBufferSize int      `config:"channel_buffer_size"`
	ChannelWorkers    int      `config:"channel_workers"`
	TimestampKey      string   `config:"timestamp_key"`
	TimestampLayout   string   `config:"timestamp_layout"`
}