Files

• Build.PL
• Changes
• LICENSE
• MANIFEST
• META.json
• META.yml
• README
• cpanfile
• dist.ini
• lib/Kafka.pm
• lib/Kafka/Connection.pm
• lib/Kafka/Consumer.pm
• lib/Kafka/Exceptions.pm
• lib/Kafka/IO.pm
• lib/Kafka/IO/Async.pm
• lib/Kafka/Int64.pm
• lib/Kafka/Internals.pm
• lib/Kafka/Message.pm
• lib/Kafka/Producer.pm
• lib/Kafka/Protocol.pm
• t/00_api.t
• t/01_bits64.t
• t/02_io.t
• t/03_io_ipv6.t
• t/04_mockio.t
• t/05_protocol.t
• t/06_decode_encode.t
• t/07_cluster.t
• t/08_cluster_start.t
• t/09_connection.t
• t/10_message.t
• t/11_producer.t
• t/12_consumer.t
• t/13_leader_not_found.t
• t/14_sasl.t
• t/20_kafka_usage.t
• t/21_kafka_bench.t
• t/30_cluster_stop.t
• t/40_autocreate_topics.t
• t/41_fork.t
• t/42_nonfatal_errors.t
• t/43_competition.t
• t/44_bad_sending.t
• t/45_compression.t
• t/46_destroy_connection.t
• t/47_kafka_usage_ipv6.t
• t/48_acknowledgement.t
• t/50_debug_level.t
• t/60_sockets.t
• t/90_mock_io.t
• t/91_mock_usage.t
• t/92_mock_bench.t
• t/99_data_cleanup.t
• t/lib/Kafka/Cluster.pm
• t/lib/Kafka/MockIO.pm
• t/lib/Kafka/MockProtocol.pm
• t/lib/Kafka/TestInternals.pm
• tools/benchmark_consumer.pl
• tools/benchmark_producer.pl
• tools/coverage.sh
• tools/profiling.pl
• tools/profiling.sh
• xt/author/02_fixme.t
• xt/author/03_vars.t
• xt/author/07_notabs.t
• xt/author/08_PureASCII.t
• xt/author/perlcritic.rc
• xt/release/01_kwalitee.t
• xt/release/03_distribution.t
• xt/release/04_pod.t
• xt/release/05_pod_coverage.t