output

Feb 13, 2020

Changes in this version

+ type KafkaAgentV1 struct

+ Agent uint32

+ Json string

+ Property string

+ Raw string

+ Timestamp uint64

+ type KafkaAttributeV1 struct

+ Attribute uint32

+ Json string

+ Property string

+ Timestamp uint64

+ Total uint64

+ type KafkaEventV1 struct

+ Event uint32

+ Json string

+ Property string

+ Timestamp uint64

+ Total uint64

+ type KafkaMessageV1 struct

+ Agent uint32

+ Attributes []uint32

+ Country string

+ Events []uint32

+ Fingerprint string

+ IPv4 string

+ Lang string

+ Origin string

+ Property string

+ Provider string

+ Referrer string

+ Session string

+ Timestamp uint64

+ type KafkaOutput struct

+ func NewKafkaOutput(wg *sync.WaitGroup, options KafkaOutputOptions, topicsV1 KafkaOutputTopicsV1) *KafkaOutput

+ func (k *KafkaOutput) Send(m *common.Message, variables map[string]string)

+ type KafkaOutputOptions struct

+ Brokers string

+ ClientID string

+ FlushFrequency int

+ FlushMaxMessages int

+ NetDialTimeout int

+ NetMaxOpenRequests int

+ NetReadTimeout int

+ NetWriteTimeout int

+ type KafkaOutputTopicsV1 struct

+ Agents string

+ Attributes string

+ DefaultPart string

+ Events string

+ Messages string