Kafka.Avro.Encode

Documentation

encodeKey :: (MonadIO m, ToAvro a) => SchemaRegistry -> Subject -> a -> m (Either EncodeError ByteString)

Encodes a provided value as a message key.

Registers the schema in SchemaRegistry with "subject-key" subject.

encodeValue :: (MonadIO m, ToAvro a) => SchemaRegistry -> Subject -> a -> m (Either EncodeError ByteString)

Encodes a provided value as a message value.

Registers the schema in SchemaRegistry with "subject-value" subject.

keySubject :: Subject -> Subject

valueSubject :: Subject -> Subject

encodeWithSchema :: (MonadIO m, ToAvro a) => SchemaRegistry -> Subject -> a -> m (Either EncodeError ByteString)

Encodes a provided value into Avro and registers value's schema in SchemaRegistry.

data EncodeError

Constructors

EncodeRegistryError SchemaRegistryError

Instances

Eq EncodeError

Methods

(==) :: EncodeError -> EncodeError -> Bool

(/=) :: EncodeError -> EncodeError -> Bool

Show EncodeError

Methods

showsPrec :: Int -> EncodeError -> ShowS

show :: EncodeError -> String

showList :: [EncodeError] -> ShowS