/ 
Confluent-SchemaRegistry-0.02
River stage one • 2 direct dependents • 2 total dependents
/ Confluent::SchemaRegistry

NAME

Confluent::SchemaRegistry - A simple client for interacting with Confluent Schema Registry.

SYNOPSIS

use Confluent::SchemaRegistry;

my $sr = Confluent::SchemaRegistry->new( { host => 'https://my-schema-registry.org' });

DESCRIPTION

Confluent::SchemaRegistry provides a simple way to interact with Confluent Schema Registry (https://docs.confluent.io/current/schema-registry/docs/index.html) enabling writing into Apache Kafka (https://kafka.apache.org/) according to Apache Avro schema specification (https://avro.apache.org/).

HEAD UP

Confluent Schema Registry documentation

Full RESTful API documentation of Schema Registry is available here: https://docs.confluent.io/current/schema-registry/docs/api.html?_ga=2.234767710.1188695207.1526911788-1213051144.1524553242#

Avro package

Avro package is a dependency of Confluent::SchemaRegistry but is not available in CPAN but it's necessary to download it from GitHub repository at: https://github.com/apache/avro/tree/master/lang/perl

Please, refer its documentation for installation.

Constructor

new( [%config] )

Construct a new Confluent::SchemaRegistry. Takes an optional hash that provides configuration flags for the REST::Client internal object.

The config flags, according to REST::Client::new specs, are:

host

The host at which Schema Registry is listening.

The default is http://localhost:8081

timeout

A timeout in seconds for requests made with the client. After the timeout the client will return a 500.

The default is 5 minutes.

cert

The path to a X509 certificate file to be used for client authentication.

The default is to not use a certificate/key pair.

key

The path to a X509 key file to be used for client authentication.

The default is to not use a certificate/key pair.

ca

The path to a certificate authority file to be used to verify host certificates.

The default is to not use a certificates authority.

pkcs12

The path to a PKCS12 certificate to be used for client authentication.

pkcs12password

The password for the PKCS12 certificate specified with 'pkcs12'.

follow

Boolean that determins whether REST::Client attempts to automatically follow redirects/authentication.

The default is false.

useragent

An LWP::UserAgent object, ready to make http requests.

REST::Client will provide a default for you if you do not set this.

METHODS

Confluent::SchemRegistry exposes the following methods.

get_response_content()

Returns the body (content) of the last method call to Schema Registry.

get_error()

Returns the error structure of the last method call to Schema Registry.

add_schema( %params )

Registers a new schema version under a subject.

Returns the generated id for the new schema or undef.

Params keys are:

SUBJECT ($scalar)

the name of the Kafka topic

TYPE ($scalar)

the type of schema ("key" or "value")

SCHEMA ($hashref or $json)

the schema to add

TODO

...

AUTHOR

Alvaro Livraghi, <alvarol@cpan.org>

CONTRIBUTE

https://github.com/alivraghi/Confluent-SchemaRegistry/issues

BUG

Please report bugs and additional features to GitHub:

https://github.com/alivraghi/Confluent-SchemaRegistry/issues

COPYRIGHT AND LICENSE

Copyright 2018 by Alvaro Livraghi

This program is free software; you can redistribute it and/or modify it under the same terms as Perl itself.