kafka

type Config struct {
	Topic         string               `json:"topic" yaml:"topic" label:"Topic"`
	Address       string               `json:"address" yaml:"address" label:"请求地址"`
	Timeout       int                  `json:"timeout" yaml:"timeout" label:"超时时间"`
	Version       string               `json:"version" yaml:"version" label:"版本"`
	PartitionType string               `json:"partition_type" yaml:"partition_type"`
	Partition     int32                `json:"partition" yaml:"partition"`
	PartitionKey  string               `json:"partition_key" yaml:"partition_key"`
	Type          string               `json:"type" yaml:"type" enum:"json,line" label:"输出格式"`
	Formatter     eosc.FormatterConfig `json:"formatter" yaml:"formatter" label:"格式化配置"`
}

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

type Factory struct {
}

type Output struct {
	*Driver
	// contains filtered or unexported fields
}

type ProducerConfig struct {
	Address       []string             `json:"address" yaml:"address"`
	Topic         string               `json:"topic" yaml:"topic"`
	Partition     int32                `json:"partition" yaml:"partition"`
	PartitionKey  string               `json:"partition_key" yaml:"partition_key"`
	PartitionType string               `json:"partition_type" yaml:"partition_type"`
	Conf          *sarama.Config       `json:"conf" yaml:"conf"`
	Type          string               `json:"type" yaml:"type"`
	Formatter     eosc.FormatterConfig `json:"formatter" yaml:"formatter"`
}