mempko

grammar Nginx
{
    rule TOP {^ .* '"' <host> <cmd> <path> <protocol> '"' <response> .* $}
    token host { \S+ }
    regex path { '/' <path-elem>? <path>?}
    token path-elem { \S+ }
    regex protocol { 'HTTP/1.1'}  
    token response { \d+ }

    proto token cmd {*}

mempko

FROM rakudo-star

RUN apt update && apt install -y  \
    librdkafka++1 \
    libssl-dev

RUN zef update
RUN zef install PKafka HTTP::Client

....

mempko

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