hw-kafka-avro-1.3.0: Avro support for Kafka infrastructure

Safe HaskellNone
LanguageHaskell2010

Kafka.Avro

Synopsis

Documentation

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.