Kafka：Kafka API（官方CPAN模块）的Perl实现-源码

[{"title":"（ 79 个子文件 214KB ） Kafka：Kafka API（官方CPAN模块）的Perl实现-源码","children":[{"title":"Kafka-master","children":[{"title":".gitignore <span style='color:#111;'> 169B </span>","children":null,"spread":false},{"title":"dist.ini <span style='color:#111;'> 314B </span>","children":null,"spread":false},{"title":"README.md <span style='color:#111;'> 31.92KB </span>","children":null,"spread":false},{"title":"t","children":[{"title":"47_kafka_usage_ipv6.t <span style='color:#111;'> 3.86KB </span>","children":null,"spread":false},{"title":"06_decode_encode.t <span style='color:#111;'> 48.54KB </span>","children":null,"spread":false},{"title":"48_acknowledgement.t <span style='color:#111;'> 9.84KB </span>","children":null,"spread":false},{"title":"60_sockets.t <span style='color:#111;'> 3.35KB </span>","children":null,"spread":false},{"title":"04_mockio.t <span style='color:#111;'> 5.58KB </span>","children":null,"spread":false},{"title":"41_fork.t <span style='color:#111;'> 8.38KB </span>","children":null,"spread":false},{"title":"44_bad_sending.t <span style='color:#111;'> 9.80KB </span>","children":null,"spread":false},{"title":"10_message.t <span style='color:#111;'> 1.24KB </span>","children":null,"spread":false},{"title":"92_mock_bench.t <span style='color:#111;'> 11.59KB </span>","children":null,"spread":false},{"title":"20_kafka_usage.t <span style='color:#111;'> 5.48KB </span>","children":null,"spread":false},{"title":"40_autocreate_topics.t <span style='color:#111;'> 4.68KB </span>","children":null,"spread":false},{"title":"50_debug_level.t <span style='color:#111;'> 6.41KB </span>","children":null,"spread":false},{"title":"08_cluster_start.t <span style='color:#111;'> 481B </span>","children":null,"spread":false},{"title":"46_destroy_connection.t <span style='color:#111;'> 2.39KB </span>","children":null,"spread":false},{"title":"90_mock_io.t <span style='color:#111;'> 8.22KB </span>","children":null,"spread":false},{"title":"45_compression.t <span style='color:#111;'> 3.92KB </span>","children":null,"spread":false},{"title":"09_connection.t <span style='color:#111;'> 14.71KB </span>","children":null,"spread":false},{"title":"42_nonfatal_errors.t <span style='color:#111;'> 16.73KB </span>","children":null,"spread":false},{"title":"12_consumer.t <span style='color:#111;'> 9.82KB </span>","children":null,"spread":false},{"title":"43_competition.t <span style='color:#111;'> 11.23KB </span>","children":null,"spread":false},{"title":"05_protocol.t <span style='color:#111;'> 6.73KB </span>","children":null,"spread":false},{"title":"11_producer.t <span style='color:#111;'> 7.97KB </span>","children":null,"spread":false},{"title":"07_cluster.t <span style='color:#111;'> 1.77KB </span>","children":null,"spread":false},{"title":"99_data_cleanup.t <span style='color:#111;'> 477B </span>","children":null,"spread":false},{"title":"02_io.t <span style='color:#111;'> 9.35KB </span>","children":null,"spread":false},{"title":"01_bits64.t <span style='color:#111;'> 3.23KB </span>","children":null,"spread":false},{"title":"21_kafka_bench.t <span style='color:#111;'> 13.12KB </span>","children":null,"spread":false},{"title":"13_leader_not_found.t <span style='color:#111;'> 2.58KB </span>","children":null,"spread":false},{"title":"03_io_ipv6.t <span style='color:#111;'> 6.13KB </span>","children":null,"spread":false},{"title":"30_cluster_stop.t <span style='color:#111;'> 578B </span>","children":null,"spread":false},{"title":"data","children":[{"title":".gitignore <span style='color:#111;'> 71B </span>","children":null,"spread":false}],"spread":false},{"title":"lib","children":[{"title":"Kafka","children":[{"title":"Cluster.pm <span style='color:#111;'> 35.69KB </span>","children":null,"spread":false},{"title":"MockIO.pm <span style='color:#111;'> 26.52KB </span>","children":null,"spread":false},{"title":"TestInternals.pm <span style='color:#111;'> 8.39KB </span>","children":null,"spread":false},{"title":"MockProtocol.pm <span style='color:#111;'> 43.60KB </span>","children":null,"spread":false}],"spread":false}],"spread":false},{"title":"91_mock_usage.t <span style='color:#111;'> 4.76KB </span>","children":null,"spread":false},{"title":"14_sasl.t <span style='color:#111;'> 5.04KB </span>","children":null,"spread":false},{"title":"00_api.t <span style='color:#111;'> 11.74KB </span>","children":null,"spread":false}],"spread":false},{"title":"inc","children":[{"title":".gitignore <span style='color:#111;'> 0B </span>","children":null,"spread":false}],"spread":true},{"title":"Changes <span style='color:#111;'> 11.41KB </span>","children":null,"spread":false},{"title":"LICENSE <span style='color:#111;'> 17.94KB </span>","children":null,"spread":false},{"title":"META.json <span style='color:#111;'> 5.87KB </span>","children":null,"spread":false},{"title":"xt","children":[{"title":"author","children":[{"title":"03_vars.t <span style='color:#111;'> 1020B </span>","children":null,"spread":false},{"title":"02_fixme.t <span style='color:#111;'> 380B </span>","children":null,"spread":false},{"title":"08_PureASCII.t <span style='color:#111;'> 842B </span>","children":null,"spread":false},{"title":"perlcritic.rc <span style='color:#111;'> 419B </span>","children":null,"spread":false},{"title":"07_notabs.t <span style='color:#111;'> 897B </span>","children":null,"spread":false}],"spread":true},{"title":"release","children":[{"title":"01_kwalitee.t <span style='color:#111;'> 222B </span>","children":null,"spread":false},{"title":"04_pod.t <span style='color:#111;'> 297B </span>","children":null,"spread":false},{"title":"05_pod_coverage.t <span style='color:#111;'> 265B </span>","children":null,"spread":false},{"title":"03_distribution.t <span style='color:#111;'> 364B </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"install_kafka.sh <span style='color:#111;'> 998B </span>","children":null,"spread":false},{"title":"Build.PL <span style='color:#111;'> 168B </span>","children":null,"spread":false},{"title":"META.yml <span style='color:#111;'> 3.11KB </span>","children":null,"spread":false},{"title":"MANIFEST <span style='color:#111;'> 1.29KB </span>","children":null,"spread":false},{"title":"verify.sh <span style='color:#111;'> 372B </span>","children":null,"spread":false},{"title":"README <span style='color:#111;'> 3.78KB </span>","children":null,"spread":false},{"title":"cpanfile <span style='color:#111;'> 3.46KB </span>","children":null,"spread":false},{"title":"tools","children":[{"title":".gitignore <span style='color:#111;'> 22B </span>","children":null,"spread":false},{"title":"benchmark_consumer.pl <span style='color:#111;'> 5.37KB </span>","children":null,"spread":false},{"title":"profiling.pl <span style='color:#111;'> 4.85KB </span>","children":null,"spread":false},{"title":"benchmark_producer.pl <span style='color:#111;'> 4.00KB </span>","children":null,"spread":false},{"title":"coverage.sh <span style='color:#111;'> 1.21KB </span>","children":null,"spread":false},{"title":"profiling.sh <span style='color:#111;'> 151B </span>","children":null,"spread":false}],"spread":false},{"title":".travis.yml <span style='color:#111;'> 458B </span>","children":null,"spread":false},{"title":"lib","children":[{"title":"Kafka.pm <span style='color:#111;'> 48.28KB </span>","children":null,"spread":false},{"title":"Kafka","children":[{"title":"Connection.pm <span style='color:#111;'> 63.11KB </span>","children":null,"spread":false},{"title":"Internals.pm <span style='color:#111;'> 10.16KB </span>","children":null,"spread":false},{"title":"Int64.pm <span style='color:#111;'> 6.75KB </span>","children":null,"spread":false},{"title":"IO","children":[{"title":"Async.pm <span style='color:#111;'> 16.22KB </span>","children":null,"spread":false}],"spread":false},{"title":"IO.pm <span style='color:#111;'> 29.86KB </span>","children":null,"spread":false},{"title":"Exceptions.pm <span style='color:#111;'> 6.82KB </span>","children":null,"spread":false},{"title":"Producer.pm <span style='color:#111;'> 16.05KB </span>","children":null,"spread":false},{"title":"Protocol.pm <span style='color:#111;'> 98.68KB </span>","children":null,"spread":false},{"title":"Message.pm <span style='color:#111;'> 6.26KB </span>","children":null,"spread":false},{"title":"Consumer.pm <span style='color:#111;'> 29.93KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":true}]