kafka

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

type KafkaInputConfig struct {
	ClientId      string `toml:"client_id"`
	Addrs         []string
	Partition     int32
	Topic         string
	Partitions    int32
	FlushInterval uint32 `toml:"flush_interval"`
}

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

type KafkaOutputConfig struct {
	ClientId      string `toml:"client_id"`
	Addrs         []string
	Partition     int32
	Topic         string
	Partitions    int32
	Distributer   string
	FlushInterval uint32 `toml:"flush_interval"`
}