Safe Haskell | None |
---|---|
Language | Haskell2010 |
Synopsis
- module Kafka.Avro.SchemaRegistry
- module Kafka.Avro.Encode
- module Kafka.Avro.Decode
- propagateKeySchema :: MonadIO m => SchemaRegistry -> Subject -> ByteString -> m (Either SchemaRegistryError (Maybe SchemaId))
- propagateValueSchema :: MonadIO m => SchemaRegistry -> Subject -> ByteString -> m (Either SchemaRegistryError (Maybe SchemaId))
Documentation
module Kafka.Avro.SchemaRegistry
module Kafka.Avro.Encode
module Kafka.Avro.Decode
propagateKeySchema :: MonadIO m => SchemaRegistry -> Subject -> ByteString -> m (Either SchemaRegistryError (Maybe SchemaId)) Source #
Registers schema that was used for a given payload against the specified subject as a key shema. It is possible that a given payload doesn't have schema registered against it, in this case no prapagation happens.
propagateValueSchema :: MonadIO m => SchemaRegistry -> Subject -> ByteString -> m (Either SchemaRegistryError (Maybe SchemaId)) Source #
Registers schema that was used for a given payload against the specified subject as a value schema. It is possible that a given payload doesn't have schema registered against it, in this case no prapagation happens.