PyPI project
kafka-python
100+ indexed releases ยท newest sdist 3.0.9 with 266 indexed members
Files in 3.0.9 kafka_python-3.0.9.tar.gz
- kafka/__init__.py
- kafka/__main__.py
- kafka/admin/__init__.py
- kafka/admin/__main__.py
- kafka/admin/_acls.py
- kafka/admin/_cluster.py
- kafka/admin/_configs.py
- kafka/admin/_groups.py
- kafka/admin/_partitions.py
- kafka/admin/_topics.py
- kafka/admin/_transactions.py
- kafka/admin/_users.py
- kafka/admin/client.py
- kafka/benchmarks/__init__.py
- kafka/benchmarks/consumer_performance.py
- kafka/benchmarks/load_example.py
- kafka/benchmarks/producer_encode_path.py
- kafka/benchmarks/producer_performance.py
- kafka/benchmarks/profile_protocol.py
- kafka/benchmarks/protocol_old_vs_new.py
- kafka/benchmarks/record_batch_compose.py
- kafka/benchmarks/record_batch_read.py
- kafka/benchmarks/varint_speed.py
- kafka/cli/__init__.py
- kafka/cli/admin/__init__.py
- kafka/cli/admin/acls/__init__.py
- kafka/cli/admin/acls/common.py
- kafka/cli/admin/acls/create.py
- kafka/cli/admin/acls/delete.py
- kafka/cli/admin/acls/describe.py
- kafka/cli/admin/cluster/__init__.py
- kafka/cli/admin/cluster/describe.py
- kafka/cli/admin/cluster/describe_quorum.py
- kafka/cli/admin/cluster/features.py
- kafka/cli/admin/cluster/log_dirs.py
- kafka/cli/admin/cluster/versions.py
- kafka/cli/admin/configs/__init__.py
- kafka/cli/admin/configs/alter.py
- kafka/cli/admin/configs/common.py
- kafka/cli/admin/configs/describe.py
- kafka/cli/admin/configs/list.py
- kafka/cli/admin/configs/reset.py
- kafka/cli/admin/groups/__init__.py
- kafka/cli/admin/groups/alter_offsets.py
- kafka/cli/admin/groups/delete.py
- kafka/cli/admin/groups/delete_offsets.py
- kafka/cli/admin/groups/describe.py
- kafka/cli/admin/groups/list.py
- kafka/cli/admin/groups/list_offsets.py
- kafka/cli/admin/groups/remove_members.py
- kafka/cli/admin/groups/reset_offsets.py
- kafka/cli/admin/partitions/__init__.py
- kafka/cli/admin/partitions/alter_reassignments.py
- kafka/cli/admin/partitions/create.py
- kafka/cli/admin/partitions/delete_records.py
- kafka/cli/admin/partitions/describe.py
- kafka/cli/admin/partitions/elect_leaders.py
- kafka/cli/admin/partitions/list_offsets.py
- kafka/cli/admin/partitions/list_reassignments.py
- kafka/cli/admin/topics/__init__.py
- kafka/cli/admin/topics/create.py
- kafka/cli/admin/topics/delete.py
- kafka/cli/admin/topics/describe.py
- kafka/cli/admin/topics/list.py
- kafka/cli/admin/transactions/__init__.py
- kafka/cli/admin/transactions/abort.py
- kafka/cli/admin/transactions/describe.py
- kafka/cli/admin/transactions/describe_producers.py
- kafka/cli/admin/transactions/find_hanging.py
- kafka/cli/admin/transactions/list.py
- kafka/cli/admin/users/__init__.py
- kafka/cli/admin/users/alter_user_scram_credentials.py
- kafka/cli/admin/users/describe_user_scram_credentials.py
- kafka/cli/common.py
- kafka/cli/consumer/__init__.py
- kafka/cli/producer/__init__.py
- kafka/cluster.py
- kafka/codec.py
- kafka/consumer/__init__.py
- kafka/consumer/__main__.py
- kafka/consumer/fetcher.py
- kafka/consumer/group.py
- kafka/consumer/subscription_state.py
- kafka/coordinator/__init__.py
- kafka/coordinator/assignors/__init__.py
- kafka/coordinator/assignors/abstract.py
- kafka/coordinator/assignors/cooperative_sticky.py
- kafka/coordinator/assignors/range.py
- kafka/coordinator/assignors/roundrobin.py
- kafka/coordinator/assignors/sticky/__init__.py
- kafka/coordinator/assignors/sticky/partition_movements.py
- kafka/coordinator/assignors/sticky/sorted_set.py
- kafka/coordinator/assignors/sticky/sticky_assignor.py
- kafka/coordinator/assignors/sticky/user_data.py
- kafka/coordinator/base.py
- kafka/coordinator/consumer.py
- kafka/coordinator/heartbeat.py
- kafka/coordinator/subscription.py
- kafka/errors.py
- kafka/future.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/net/__init__.py
- kafka/net/compat.py
- kafka/net/connection.py
- kafka/net/http_connect.py
- kafka/net/inet.py
- kafka/net/manager.py
- kafka/net/metrics.py
- kafka/net/sasl/__init__.py
- kafka/net/sasl/abc.py
- kafka/net/sasl/gssapi.py
- kafka/net/sasl/msk.py
- kafka/net/sasl/oauth.py
- kafka/net/sasl/plain.py
- kafka/net/sasl/scram.py
- kafka/net/sasl/sspi.py
- kafka/net/selector.py
- kafka/net/socks5.py
- kafka/net/transport.py
- kafka/net/wakeup_notifier.py
- kafka/partitioner/__init__.py
- kafka/partitioner/abc.py
- kafka/partitioner/default.py
- kafka/partitioner/sticky.py
- kafka/producer/__init__.py
- kafka/producer/__main__.py
- kafka/producer/future.py
- kafka/producer/kafka.py
- kafka/producer/producer_batch.py
- kafka/producer/record_accumulator.py
- kafka/producer/sender.py
- kafka/producer/transaction_manager.py
- kafka/protocol/__init__.py
- kafka/protocol/admin/__init__.py
- kafka/protocol/admin/acl.py
- kafka/protocol/admin/client_quotas.py
- kafka/protocol/admin/cluster.py
- kafka/protocol/admin/configs.py
- kafka/protocol/admin/groups.py
- kafka/protocol/admin/topics.py
- kafka/protocol/admin/transactions.py
- kafka/protocol/admin/users.py
- kafka/protocol/api_data.py
- kafka/protocol/api_header.py
- kafka/protocol/api_key.py
- kafka/protocol/api_message.py
- kafka/protocol/broker_version_data.py
- kafka/protocol/consumer/__init__.py
- kafka/protocol/consumer/fetch.py
- kafka/protocol/consumer/group.py
- kafka/protocol/consumer/metadata.py
- kafka/protocol/consumer/offsets.py
- kafka/protocol/data_container.py
- kafka/protocol/frame.py
- kafka/protocol/generate_stubs.py
- kafka/protocol/metadata/__init__.py
- kafka/protocol/metadata/api_versions.py
- kafka/protocol/metadata/find_coordinator.py
- kafka/protocol/metadata/metadata.py
- kafka/protocol/old/__init__.py
- kafka/protocol/old/abstract.py
- kafka/protocol/old/add_offsets_to_txn.py
- kafka/protocol/old/add_partitions_to_txn.py
- kafka/protocol/old/admin.py
- kafka/protocol/old/api.py
- kafka/protocol/old/api_versions.py
- kafka/protocol/old/commit.py
- kafka/protocol/old/consumer_protocol.py
- kafka/protocol/old/end_txn.py
- kafka/protocol/old/fetch.py
- kafka/protocol/old/find_coordinator.py
- kafka/protocol/old/group.py
- kafka/protocol/old/init_producer_id.py
- kafka/protocol/old/list_offsets.py
- kafka/protocol/old/metadata.py
- kafka/protocol/old/offset_for_leader_epoch.py
- kafka/protocol/old/produce.py
- kafka/protocol/old/sasl_authenticate.py
- kafka/protocol/old/sasl_handshake.py
- kafka/protocol/old/struct.py
- kafka/protocol/old/txn_offset_commit.py
- kafka/protocol/old/types.py
- kafka/protocol/parser.py
- kafka/protocol/producer/__init__.py
- kafka/protocol/producer/produce.py
- kafka/protocol/producer/transaction.py
- kafka/protocol/sasl.py
- kafka/protocol/schemas/__init__.py
- kafka/protocol/schemas/fields/__init__.py
- kafka/protocol/schemas/fields/array.py
- kafka/protocol/schemas/fields/base.py
- kafka/protocol/schemas/fields/codecs/__init__.py
- kafka/protocol/schemas/fields/codecs/encode_buffer.py
- kafka/protocol/schemas/fields/codecs/tagged_fields.py
- kafka/protocol/schemas/fields/codecs/types.py
- kafka/protocol/schemas/fields/codegen.py
- kafka/protocol/schemas/fields/simple.py
- kafka/protocol/schemas/fields/struct.py
- kafka/protocol/schemas/fields/struct_array.py
- kafka/protocol/schemas/load_json.py
- kafka/protocol/schemas/resources/__init__.py
- kafka/record/__init__.py
- kafka/record/_crc32c.py
- kafka/record/abc.py
- kafka/record/default_records.py
- kafka/record/legacy_records.py
- kafka/record/memory_records.py
- kafka/record/util.py
- kafka/serializer/__init__.py
- kafka/serializer/abstract.py
- kafka/serializer/default.py
- kafka/serializer/json.py
- kafka/serializer/wrapper.py
- kafka/structs.py
- kafka/util.py
- kafka/vendor/__init__.py
- kafka/version.py
- test/integration/__init__.py
- test/integration/conftest.py
- test/integration/fixtures.py
- test/integration/test_admin_integration.py
- test/integration/test_consumer_integration.py
- test/integration/test_producer_integration.py
- test/integration/test_sasl_integration.py
- test/integration/test_ssl_integration.py
- test/net/__init__.py
- test/net/test_compat.py
- test/net/test_connection.py
- test/net/test_http_connect.py
- test/net/test_inet.py
- test/net/test_manager.py
- test/net/test_sasl_reauthentication.py
- test/net/test_selector.py
- test/net/test_transport.py
- test/net/test_wakeup_notifier.py
- test/test_cluster.py
- test/test_codec.py
- test/test_future.py
- test/test_metrics.py
- test/test_mock_broker.py
- test/test_package.py
- test/test_util.py
- test/testutil.py
Indexed releases
- 3.0.9
kafka_python-3.0.9.tar.gz266 members - 3.0.8
kafka_python-3.0.8.tar.gz266 members - 3.0.7
kafka_python-3.0.7.tar.gz266 members - 3.0.6
kafka_python-3.0.6.tar.gz266 members - 3.0.5
kafka_python-3.0.5.tar.gz266 members - 3.0.4
kafka_python-3.0.4.tar.gz266 members - 3.0.2
kafka_python-3.0.2.tar.gz266 members - 3.0.1
kafka_python-3.0.1.tar.gz266 members - 3.0.0
kafka_python-3.0.0.tar.gz266 members - 2.3.2
kafka_python-2.3.2.tar.gz179 members - 2.3.1
kafka_python-2.3.1.tar.gz179 members - 2.3.0
kafka_python-2.3.0.tar.gz180 members - 2.2.20
kafka_python-2.2.20.tar.gz153 members - 2.2.19
kafka_python-2.2.19.tar.gz153 members - 2.2.18
kafka_python-2.2.18.tar.gz154 members - 2.2.17
kafka_python-2.2.17.tar.gz154 members - 2.2.16
kafka_python-2.2.16.tar.gz154 members - 2.2.15
kafka_python-2.2.15.tar.gz154 members - 2.2.14
kafka_python-2.2.14.tar.gz154 members - 2.2.13
kafka_python-2.2.13.tar.gz154 members - 2.2.12
kafka_python-2.2.12.tar.gz154 members - 2.2.11
kafka_python-2.2.11.tar.gz154 members - 2.2.10
kafka_python-2.2.10.tar.gz154 members - 2.2.9
kafka_python-2.2.9.tar.gz154 members - 2.2.8
kafka_python-2.2.8.tar.gz154 members - 2.2.7
kafka_python-2.2.7.tar.gz154 members - 2.2.6
kafka_python-2.2.6.tar.gz154 members - 2.2.5
kafka_python-2.2.5.tar.gz154 members - 2.2.4
kafka_python-2.2.4.tar.gz154 members - 2.2.3
kafka_python-2.2.3.tar.gz154 members - 2.2.2
kafka_python-2.2.2.tar.gz154 members - 2.2.1
kafka_python-2.2.1.tar.gz154 members - 2.2.0
kafka_python-2.2.0.tar.gz154 members - 2.1.6
kafka_python-2.1.6.tar.gz143 members - 2.1.5
kafka_python-2.1.5.tar.gz143 members - 2.1.4
kafka_python-2.1.4.tar.gz137 members - 2.1.3
kafka_python-2.1.3.tar.gz137 members - 2.1.2
kafka_python-2.1.2.tar.gz136 members - 2.1.1
kafka_python-2.1.1.tar.gz136 members - 2.1.0
kafka_python-2.1.0.tar.gz136 members - 2.0.6
kafka_python-2.0.6.tar.gz124 members - 2.0.5
kafka_python-2.0.5.tar.gz124 members - 2.0.4
kafka_python-2.0.4.tar.gz124 members - 2.0.3
kafka_python-2.0.3-py2.py3-none-any.whl98 members - 2.0.2
kafka_python-2.0.2-py2.py3-none-any.whl98 members - 2.0.1
kafka_python-2.0.1-py2.py3-none-any.whl94 members - 2.0.0
kafka_python-2.0.0-py2.py3-none-any.whl94 members - 1.4.7
kafka_python-1.4.7-py2.py3-none-any.whl106 members - 1.4.6
kafka_python-1.4.6-py2.py3-none-any.whl105 members - 1.4.5
kafka_python-1.4.5-py2.py3-none-any.whl103 members - 1.4.4
kafka_python-1.4.4-py2.py3-none-any.whl103 members - 1.4.3
kafka_python-1.4.3-py2.py3-none-any.whl97 members - 1.4.2
kafka_python-1.4.2-py2.py3-none-any.whl97 members - 1.4.1
kafka_python-1.4.1-py2.py3-none-any.whl97 members - 1.4.0
kafka_python-1.4.0-py2.py3-none-any.whl97 members - 1.3.5
kafka_python-1.3.5-py2.py3-none-any.whl89 members - 1.3.4
kafka_python-1.3.4-py2.py3-none-any.whl88 members - 1.3.3
kafka_python-1.3.3-py2.py3-none-any.whl88 members - 1.3.2
kafka_python-1.3.2-py2.py3-none-any.whl88 members - 1.3.1
kafka_python-1.3.1-py2.py3-none-any.whl86 members - 1.3.0
kafka_python-1.3.0-py2.py3-none-any.whl86 members - 1.2.5
kafka_python-1.2.5-py2.py3-none-any.whl84 members - 1.2.4
kafka_python-1.2.4-py2.py3-none-any.whl84 members - 1.2.3
kafka_python-1.2.3-py2.py3-none-any.whl84 members - 1.2.2
kafka_python-1.2.2-py2.py3-none-any.whl84 members - 1.2.1
kafka_python-1.2.1-py2.py3-none-any.whl84 members - 1.2.0
kafka_python-1.2.0-py2.py3-none-any.whl84 members - 1.1.1
kafka_python-1.1.1-py2.py3-none-any.whl84 members - 1.1.0
kafka_python-1.1.0-py2.py3-none-any.whl84 members - 1.0.2
kafka_python-1.0.2-py2.py3-none-any.whl56 members - 1.0.1
kafka_python-1.0.1-py2-none-any.whl56 members - 1.0.0
kafka_python-1.0.0-py2.py3-none-any.whl55 members - 0.9.5
kafka-python-0.9.5.tar.gz38 members - 0.9.3
kafka-python-0.9.3.tar.gz37 members - 0.9.1
kafka-python-0.9.1.tar.gz24 members - 3.0.9
kafka_python-3.0.9-py3-none-any.whl240 members - 3.0.8
kafka_python-3.0.8-py3-none-any.whl240 members - 3.0.7
kafka_python-3.0.7-py3-none-any.whl240 members - 3.0.6
kafka_python-3.0.6-py3-none-any.whl240 members - 3.0.5
kafka_python-3.0.5-py3-none-any.whl240 members - 3.0.4
kafka_python-3.0.4-py3-none-any.whl240 members - 3.0.2
kafka_python-3.0.2-py3-none-any.whl240 members - 3.0.1
kafka_python-3.0.1-py3-none-any.whl240 members - 3.0.0
kafka_python-3.0.0-py3-none-any.whl240 members - 2.3.2
kafka_python-2.3.2-py2.py3-none-any.whl147 members - 2.3.1
kafka_python-2.3.1-py2.py3-none-any.whl147 members - 2.3.0
kafka_python-2.3.0-py2.py3-none-any.whl147 members - 2.2.20
kafka_python-2.2.20-py2.py3-none-any.whl122 members - 2.2.19
kafka_python-2.2.19-py2.py3-none-any.whl122 members - 2.2.18
kafka_python-2.2.18-py2.py3-none-any.whl122 members - 2.2.17
kafka_python-2.2.17-py2.py3-none-any.whl122 members - 2.2.16
kafka_python-2.2.16-py2.py3-none-any.whl122 members - 2.2.15
kafka_python-2.2.15-py2.py3-none-any.whl122 members - 2.2.14
kafka_python-2.2.14-py2.py3-none-any.whl122 members - 2.2.13
kafka_python-2.2.13-py2.py3-none-any.whl122 members - 2.2.12
kafka_python-2.2.12-py2.py3-none-any.whl122 members - 2.2.11
kafka_python-2.2.11-py2.py3-none-any.whl122 members - 2.2.10
kafka_python-2.2.10-py2.py3-none-any.whl122 members - 2.2.9
kafka_python-2.2.9-py2.py3-none-any.whl122 members - 2.2.8
kafka_python-2.2.8-py2.py3-none-any.whl122 members
and more releases past the first 100