Example usage of Perl 6 Kafka library in progress.

kafka_example.p6

use v6;

use lib 'lib/kafka';
use Kafka;

sub MAIN () 
{
    my $consumer = Kafka::Consumer.new( topic=>"test", brokers=>"192.168.0.5");

    $consumer.messages.tap(-> $msg 
    {
        given $msg 
        {
            when Kafka::Message
            {
                say "got {$msg.offset}: { $msg.payload } ";
            }
            when Kafka::EOF
            {
                say "Messages Consumed { $msg.total-consumed}";
                $consumer.stop;
            }
            when Kafka::Error
            {
                say "Error {$msg.what}";
                $consumer.stop;
            }
        }
    });

    await $consumer.consume-from-beginning(0);
}