CPAN::Groonga

ssage key (valid JSON-string)
  my $key_schema = <<KEY_SCHEMA;
  	{
  		"type": "long",
  		"name": "_id"
  	}
  KEY_SCHEMA
  # Set Avro schema for message value (payload) (valid JSON-string)
  my $va

 and extends L<Kafka::Producer|Kafka::Producer>.

=cut

use 5.010;
use strict;
use warnings;

use JSON::XS;

use base 'Kafka::Producer';

use Avro::BinaryEncoder;
use Avro::Schema;
use Confluent::Sche

CHEMA => $supplied_schema
			);
			$self->_set_error('Error adding schema to registry: ' . encode_json($sr->get_error())) &&
				return undef
					unless $schema_id;
			
			# ...and bless new schema i