Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RemoveMagicHeader ¶
RemoveMagicHeader reads the five bytes from the reader to remove the magic header.
Types ¶
type AvroEncoder ¶
AvroEncoder encodes schemaId and Avro message.
func (*AvroEncoder) Encode ¶
func (a *AvroEncoder) Encode() ([]byte, error)
Encode configured schemaId and Avro content into bytes.
type AvroEncoderBuilder ¶
type AvroEncoderBuilder interface {
BuildEncoder(subject string, avro Avro) (sarama.Encoder, error)
}
AvroEncoderBuilder create a sarama.Encoder for the given Avro object and subject.
func NewAvroEncoderBuilder ¶
func NewAvroEncoderBuilder( schemaRegistry Registry, ) AvroEncoderBuilder
NewAvroSchemaEncoderBuilder returns a AvroEncoderBuilder.
Click to show internal directories.
Click to hide internal directories.