Versions in this module Expand all Collapse all v1 v1.0.0 Jan 4, 2023 Changes in this version + type DeserializerConfig struct + func NewDeserializerConfig() *DeserializerConfig + type GenericDeserializer struct + func NewGenericDeserializer(client schemaregistry.Client, serdeType serde.Type, conf *DeserializerConfig) (*GenericDeserializer, error) + func (s *GenericDeserializer) Deserialize(topic string, payload []byte) (interface{}, error) + func (s *GenericDeserializer) DeserializeInto(topic string, payload []byte, msg interface{}) error + type GenericSerializer struct + func NewGenericSerializer(client schemaregistry.Client, serdeType serde.Type, conf *SerializerConfig) (*GenericSerializer, error) + func (s *GenericSerializer) Serialize(topic string, msg interface{}) ([]byte, error) + type SerializerConfig struct + func NewSerializerConfig() *SerializerConfig + type SpecificAvroMessage interface + Schema func() string + Serialize func(w io.Writer) error + type SpecificDeserializer struct + func NewSpecificDeserializer(client schemaregistry.Client, serdeType serde.Type, conf *DeserializerConfig) (*SpecificDeserializer, error) + func (s *SpecificDeserializer) Deserialize(topic string, payload []byte) (interface{}, error) + func (s *SpecificDeserializer) DeserializeInto(topic string, payload []byte, msg interface{}) error + type SpecificSerializer struct + func NewSpecificSerializer(client schemaregistry.Client, serdeType serde.Type, conf *SerializerConfig) (*SpecificSerializer, error) + func (s *SpecificSerializer) Serialize(topic string, msg interface{}) ([]byte, error)