Versions in this module Expand all Collapse all v1 v1.0.0 Sep 23, 2022 Changes in this version + type Deserializer struct + func NewDeserializer(client schemaregistry.Client, serdeType serde.Type, conf *DeserializerConfig) (*Deserializer, error) + func (s *Deserializer) Deserialize(topic string, payload []byte) (interface{}, error) + func (s *Deserializer) DeserializeInto(topic string, payload []byte, msg interface{}) error + type DeserializerConfig struct + EnableValidation bool + func NewDeserializerConfig() *DeserializerConfig + type Serializer struct + func NewSerializer(client schemaregistry.Client, serdeType serde.Type, conf *SerializerConfig) (*Serializer, error) + func (s *Serializer) Serialize(topic string, msg interface{}) ([]byte, error) + type SerializerConfig struct + EnableValidation bool + func NewSerializerConfig() *SerializerConfig
Go to main page