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
xt/author/02_fixme.t
xt/author/03_vars.t
xt/author/07_notabs.t
xt/author/08_PureASCII.t
xt/author/perlcritic.rc
t/lib/Kafka/Cluster.pm
t/lib/Kafka/MockIO.pm
t/lib/Kafka/MockProtocol.pm
t/lib/Kafka/TestInternals.pm
xt/release/01_kwalitee.t
xt/release/03_distribution.t
xt/release/04_pod.t
xt/release/05_pod_coverage.t
tools/benchmark_consumer.pl
tools/benchmark_producer.pl
tools/coverage.sh
tools/profiling.pl
tools/profiling.sh