Versions in this module Expand all Collapse all v2 v2.0.0 Jan 19, 2023 Changes in this version + type Deserializer struct + ProtoRegistry *protoregistry.Types + func NewDeserializer(client schemaregistry.Client, serdeType serde.Type, conf *DeserializerConfig) (*Deserializer, error) + func (s *Deserializer) ConfigureDeserializer(client schemaregistry.Client, serdeType serde.Type, ...) 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 + 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 + func NewSerializerConfig() *SerializerConfig
Go to main page