producer

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

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

type Flags struct {
	Partitioner        string
	RequiredAcks       string
	Partition          int32
	Separator          string
	LineSeparator      string
	File               string
	Key                string
	Value              string
	NullValue          bool
	Headers            []string
	KeySchemaVersion   int
	ValueSchemaVersion int
	KeyEncoding        string
	ValueEncoding      string
	Silent             bool
	RateInSeconds      int
	ProtoFiles         []string
	ProtoImportPaths   []string
	ProtosetFiles      []string
	KeyProtoType       string
	ValueProtoType     string
}

type MessageSerializer interface {
	CanSerialize(topic string) (bool, error)
	Serialize(key, value []byte, flags Flags) (*sarama.ProducerMessage, error)
}

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

type Operation struct {
}

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