and extends L<Kafka::Consumer|Kafka::Consumer>. =cut use 5.010; use strict; use warnings; use JSON::XS; use IO::String; use base 'Kafka::Consumer'; use Avro::BinaryDecoder; use Avro::Schema; use