Python库 | kafka-1.2.4.tar.gz

AUTHORS.md CHANGES.md LICENSE MANIFEST.in README.rst setup.cfg setup.py kafka/__init__.py kafka/client.py kafka/client_async.py kafka/cluster.py kafka/codec.py kafka/common.py kafka/conn.py kafka/context.py kafka/errors.py kafka/future.py kafka/selectors34.py kafka/socketpair.py kafka/structs.py kafka/util.py kafka/version.py kafka.egg-info/PKG-INFO kafka.egg-info/SOURCES.txt kafka.egg-info/dependency_links.txt kafka.egg-info/requires.txt kafka.egg-info/top_level.txt kafka/consumer/__init__.py kafka/consumer/base.py kafka/consumer/fetcher.py kafka/consumer/group.py kafka/consumer/multiprocess.py kafka/consumer/simple.py kafka/consumer/subscription_state.py kafka/coordinator/__init__.py kafka/coordinator/base.py kafka/coordinator/consumer.py kafka/coordinator/heartbeat.py kafka/coordinator/protocol.py kafka/coordinator/assignors/__init__.py kafka/coordinator/assignors/abstract.py kafka/coordinator/assignors/range.py kafka/coordinator/assignors/roundrobin.py kafka/metrics/__init__.py kafka/metrics/compound_stat.py kafka/metrics/dict_reporter.py kafka/metrics/kafka_metric.py kafka/metrics/measurable.py kafka/metrics/measurable_stat.py kafka/metrics/metric_config.py kafka/metrics/metric_name.py kafka/metrics/metrics.py kafka/metrics/metrics_reporter.py kafka/metrics/quota.py kafka/metrics/stat.py kafka/metrics/stats/__init__.py kafka/metrics/stats/avg.py kafka/metrics/stats/count.py kafka/metrics/stats/histogram.py kafka/metrics/stats/max_stat.py kafka/metrics/stats/min_stat.py kafka/metrics/stats/percentile.py kafka/metrics/stats/percentiles.py kafka/metrics/stats/rate.py kafka/metrics/stats/sampled_stat.py kafka/metrics/stats/sensor.py kafka/metrics/stats/total.py kafka/partitioner/__init__.py kafka/partitioner/base.py kafka/partitioner/default.py kafka/partitioner/hashed.py kafka/partitioner/roundrobin.py kafka/producer/__init__.py kafka/producer/base.py kafka/producer/buffer.py kafka/producer/future.py kafka/producer/kafka.py kafka/producer/keyed.py kafka/producer/record_accumulator.py kafka/producer/sender.py kafka/producer/simple.py kafka/protocol/__init__.py kafka/protocol/abstract.py kafka/protocol/admin.py kafka/protocol/api.py kafka/protocol/commit.py kafka/protocol/fetch.py kafka/protocol/group.py kafka/protocol/legacy.py kafka/protocol/message.py kafka/protocol/metadata.py kafka/protocol/offset.py kafka/protocol/pickle.py kafka/protocol/produce.py kafka/protocol/struct.py kafka/protocol/types.py test/test_assignors.py test/test_client.py test/test_client_async.py test/test_client_integration.py test/test_codec.py test/test_conn.py test/test_conn_legacy.py test/test_consumer.py test/test_consumer_group.py test/test_consumer_integration.py test/test_context.py test/test_coordinator.py test/test_failover_integration.py test/test_fetcher.py test/test_metrics.py test/test_package.py test/test_partitioner.py test/test_producer.py test/test_producer_integration.py test/test_producer_legacy.py test/test_protocol.py test/test_protocol_legacy.py test/test_sender.py test/test_util.py test/testutil.py