Files

• Changes
• MANIFEST
• MANIFEST.SKIP
• META.json
• META.yml
• Makefile.PL
• README
• bench/benchmark.pl
• bench/latency.pl
• eg/admin.pl
• eg/anyevent.pl
• eg/consume.pl
• eg/consumer_group.pl
• eg/error_handling.pl
• eg/fire_and_forget.pl
• eg/json_events.pl
• eg/low_level.pl
• eg/manual_commit.pl
• eg/metrics.pl
• eg/multi_partition.pl
• eg/multi_topic.pl
• eg/produce.pl
• eg/produce_headers.pl
• eg/reconnect.pl
• eg/request_reply.pl
• eg/tail.pl
• lib/EV/Kafka.pm
• src/EV__Kafka.xs
• src/ngx-queue.h
• src/ppport.h
• t/00_load.t
• t/01_connect.t
• t/02_produce.t
• t/03_fetch.t
• t/04_cluster.t
• t/05_consumer_group.t
• t/06_murmur2.t
• t/07_unit.t
• t/08_error_name.t
• t/09_crc32c.t
• t/10_error_paths.t
• t/11_sticky_assign.t
• t/12_compression.t
• t/13_transactions.t
• t/14_txn_offset_commit.t
• typemap
• xt/asan.t
• xt/cppcheck.t
• xt/multi_broker.t
• xt/valgrind.t