Files

• Changes
• MANIFEST
• META.json
• META.yml
• Makefile.PL
• README
• lib/Kafka.pm
• lib/Kafka/Connection.pm
• lib/Kafka/Consumer.pm
• lib/Kafka/Exceptions.pm
• lib/Kafka/IO.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_mockio.t
• t/04_protocol.t
• t/05_decode_encode.t
• t/06_cluster.t
• t/07_cluster_start.t
• t/08_connection.t
• t/09_message.t
• t/10_producer.t
• t/11_consumer.t
• t/70_kafka_usage.t
• t/71_kafka_bench.t
• t/89_cluster_stop.t
• t/90_mock_io.t
• t/91_mock_usage.t
• t/92_mock_bench.t
• t/bin/kafka-run-class.sh
• t/config/log4j.properties
• t/config/server.properties
• t/config/zookeeper.properties
• 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/.perlcriticrc
• xt/author/01_collection.t
• xt/author/02_fixme.t
• xt/author/03_vars.t
• xt/author/04_versions.t
• xt/author/05_critic.t
• xt/author/06_eol.t
• xt/author/07_notabs.t
• xt/author/08_PureASCII.t
• xt/release/01_kwalitee.t
• xt/release/02_distribution.t
• xt/release/03_pod.t
• xt/release/04_pod_coverage.t