Versions in this module Expand all Collapse all v3 v3.4.4 Jun 18, 2020 v3.4.3 Jun 18, 2020 Changes in this version + var KafkaBrk *string + var KafkaHashing *bool + var KafkaKeying *string + var KafkaLogErrors *bool + var KafkaSASL *bool + var KafkaSrv *string + var KafkaTLS *bool + var KafkaTopic *string + var KafkaVersion *string + func HashProto(fields []string, flowMessage *flowmessage.FlowMessage) string + func ParseKafkaVersion(versionString string) (sarama.KafkaVersion, error) + func RegisterFlags() + func SetKafkaVersion(version sarama.KafkaVersion) + type KafkaState struct + FixedLengthProto bool + func StartKafkaProducer(addrs []string, topic string, hashing bool, keying string, useTls bool, ...) (*KafkaState, error) + func StartKafkaProducerFromArgs(log utils.Logger) (*KafkaState, error) + func (s KafkaState) Publish(msgs []*flowmessage.FlowMessage) + func (s KafkaState) SendKafkaFlowMessage(flowMessage *flowmessage.FlowMessage) Other modules containing this package github.com/Scorcher/goflow