Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewKafkaOutput ¶
Types ¶
type KafkaConfig ¶
type KafkaConfig struct {
Base config.ConfigBase
Broker string `yaml:"broker"`
Topic string `yaml:"topic"`
}
type KafkaOutput ¶
type KafkaOutput struct {
// contains filtered or unexported fields
}
func (*KafkaOutput) Run ¶
func (output *KafkaOutput) Run()
func (*KafkaOutput) Send ¶
func (output *KafkaOutput) Send(doc map[string]interface{})
func (*KafkaOutput) Stop ¶
func (output *KafkaOutput) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.