NAME Kafka::Consumer::Avro - Avro message consumer for Apache Kafka. SYNOPSIS use Kafka::Connection; use Kafka::Consumer::Avro; my $connection = Kafka::Connection->new( host => 'localhost' ); my $consumer = Kafka::Consumer::Avro->new( Connection => $connection ); # Do some interactions with Avro & SchemaRegistry before sending messages # Fetch messages my $response = $consumer->fetch(...); # Closes the consumer and cleans up undef $consumer; $connection->close; undef $connection; DESCRIPTION "Kafka::Consumer::Avro" main feature is to provide object-oriented API to consume messages according to *Confluent SchemaRegistry* and *Avro* serialization. "Kafka::Consumer::Avro" inerhits from and extends Kafka::Consumer. CONSTRUCTOR "new" Creates new consumer client object. "new()" takes arguments in key-value pairs as described in Kafka::Consumer from which it inherits. In addition, takes in the following arguments: "SchemaRegistry => $schema_registry" (mandatory) Is a Confluent::SchemaRegistry instance. METHODS The following methods are defined for the "Kafka::Avro::Consumer" class: "schema_registry"() Returns the Confluent::SchemaRegistry instance supplied to the construcor. "get_error"() Returns a string containing last error message. "fetch( %params )" Gets messages froma a Kafka topic. Please, see Kafka::Consumer for more details. AUTHOR Alvaro Livraghi, CONTRIBUTE BUGS Please use GitHub project link above to report problems or contact authors. 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.