AUTHORS.md
CHANGES.md
LICENSE
MANIFEST.in
README.rst
pyproject.toml
kafka/__init__.py
kafka/__main__.py
kafka/cluster.py
kafka/codec.py
kafka/errors.py
kafka/future.py
kafka/structs.py
kafka/util.py
kafka/version.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/common.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/consumer/__init__.py
kafka/cli/producer/__init__.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/base.py
kafka/coordinator/consumer.py
kafka/coordinator/heartbeat.py
kafka/coordinator/subscription.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/StickyAssignorUserData.json
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/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/selector.py
kafka/net/socks5.py
kafka/net/transport.py
kafka/net/wakeup_notifier.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/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/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/data_container.py
kafka/protocol/frame.py
kafka/protocol/generate_stubs.py
kafka/protocol/parser.py
kafka/protocol/sasl.py
kafka/protocol/sasl.pyi
kafka/protocol/admin/__init__.py
kafka/protocol/admin/acl.py
kafka/protocol/admin/acl.pyi
kafka/protocol/admin/client_quotas.py
kafka/protocol/admin/client_quotas.pyi
kafka/protocol/admin/cluster.py
kafka/protocol/admin/cluster.pyi
kafka/protocol/admin/configs.py
kafka/protocol/admin/configs.pyi
kafka/protocol/admin/groups.py
kafka/protocol/admin/groups.pyi
kafka/protocol/admin/topics.py
kafka/protocol/admin/topics.pyi
kafka/protocol/admin/transactions.py
kafka/protocol/admin/transactions.pyi
kafka/protocol/admin/users.py
kafka/protocol/admin/users.pyi
kafka/protocol/consumer/__init__.py
kafka/protocol/consumer/fetch.py
kafka/protocol/consumer/fetch.pyi
kafka/protocol/consumer/group.py
kafka/protocol/consumer/group.pyi
kafka/protocol/consumer/metadata.py
kafka/protocol/consumer/metadata.pyi
kafka/protocol/consumer/offsets.py
kafka/protocol/consumer/offsets.pyi
kafka/protocol/metadata/__init__.py
kafka/protocol/metadata/api_versions.py
kafka/protocol/metadata/api_versions.pyi
kafka/protocol/metadata/find_coordinator.py
kafka/protocol/metadata/find_coordinator.pyi
kafka/protocol/metadata/metadata.py
kafka/protocol/metadata/metadata.pyi
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/producer/__init__.py
kafka/protocol/producer/produce.py
kafka/protocol/producer/produce.pyi
kafka/protocol/producer/transaction.py
kafka/protocol/producer/transaction.pyi
kafka/protocol/schemas/__init__.py
kafka/protocol/schemas/load_json.py
kafka/protocol/schemas/fields/__init__.py
kafka/protocol/schemas/fields/array.py
kafka/protocol/schemas/fields/base.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/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/resources/AddOffsetsToTxnRequest.json
kafka/protocol/schemas/resources/AddOffsetsToTxnResponse.json
kafka/protocol/schemas/resources/AddPartitionsToTxnRequest.json
kafka/protocol/schemas/resources/AddPartitionsToTxnResponse.json
kafka/protocol/schemas/resources/AlterClientQuotasRequest.json
kafka/protocol/schemas/resources/AlterClientQuotasResponse.json
kafka/protocol/schemas/resources/AlterConfigsRequest.json
kafka/protocol/schemas/resources/AlterConfigsResponse.json
kafka/protocol/schemas/resources/AlterPartitionReassignmentsRequest.json
kafka/protocol/schemas/resources/AlterPartitionReassignmentsResponse.json
kafka/protocol/schemas/resources/AlterReplicaLogDirsRequest.json
kafka/protocol/schemas/resources/AlterReplicaLogDirsResponse.json
kafka/protocol/schemas/resources/AlterUserScramCredentialsRequest.json
kafka/protocol/schemas/resources/AlterUserScramCredentialsResponse.json
kafka/protocol/schemas/resources/ApiVersionsRequest.json
kafka/protocol/schemas/resources/ApiVersionsResponse.json
kafka/protocol/schemas/resources/ConsumerProtocolAssignment.json
kafka/protocol/schemas/resources/ConsumerProtocolSubscription.json
kafka/protocol/schemas/resources/CreateAclsRequest.json
kafka/protocol/schemas/resources/CreateAclsResponse.json
kafka/protocol/schemas/resources/CreatePartitionsRequest.json
kafka/protocol/schemas/resources/CreatePartitionsResponse.json
kafka/protocol/schemas/resources/CreateTopicsRequest.json
kafka/protocol/schemas/resources/CreateTopicsResponse.json
kafka/protocol/schemas/resources/DeleteAclsRequest.json
kafka/protocol/schemas/resources/DeleteAclsResponse.json
kafka/protocol/schemas/resources/DeleteGroupsRequest.json
kafka/protocol/schemas/resources/DeleteGroupsResponse.json
kafka/protocol/schemas/resources/DeleteRecordsRequest.json
kafka/protocol/schemas/resources/DeleteRecordsResponse.json
kafka/protocol/schemas/resources/DeleteTopicsRequest.json
kafka/protocol/schemas/resources/DeleteTopicsResponse.json
kafka/protocol/schemas/resources/DescribeAclsRequest.json
kafka/protocol/schemas/resources/DescribeAclsResponse.json
kafka/protocol/schemas/resources/DescribeClientQuotasRequest.json
kafka/protocol/schemas/resources/DescribeClientQuotasResponse.json
kafka/protocol/schemas/resources/DescribeClusterRequest.json
kafka/protocol/schemas/resources/DescribeClusterResponse.json
kafka/protocol/schemas/resources/DescribeConfigsRequest.json
kafka/protocol/schemas/resources/DescribeConfigsResponse.json
kafka/protocol/schemas/resources/DescribeGroupsRequest.json
kafka/protocol/schemas/resources/DescribeGroupsResponse.json
kafka/protocol/schemas/resources/DescribeLogDirsRequest.json
kafka/protocol/schemas/resources/DescribeLogDirsResponse.json
kafka/protocol/schemas/resources/DescribeProducersRequest.json
kafka/protocol/schemas/resources/DescribeProducersResponse.json
kafka/protocol/schemas/resources/DescribeQuorumRequest.json
kafka/protocol/schemas/resources/DescribeQuorumResponse.json
kafka/protocol/schemas/resources/DescribeTopicPartitionsRequest.json
kafka/protocol/schemas/resources/DescribeTopicPartitionsResponse.json
kafka/protocol/schemas/resources/DescribeTransactionsRequest.json
kafka/protocol/schemas/resources/DescribeTransactionsResponse.json
kafka/protocol/schemas/resources/DescribeUserScramCredentialsRequest.json
kafka/protocol/schemas/resources/DescribeUserScramCredentialsResponse.json
kafka/protocol/schemas/resources/ElectLeadersRequest.json
kafka/protocol/schemas/resources/ElectLeadersResponse.json
kafka/protocol/schemas/resources/EndTxnRequest.json
kafka/protocol/schemas/resources/EndTxnResponse.json
kafka/protocol/schemas/resources/FetchRequest.json
kafka/protocol/schemas/resources/FetchResponse.json
kafka/protocol/schemas/resources/FindCoordinatorRequest.json
kafka/protocol/schemas/resources/FindCoordinatorResponse.json
kafka/protocol/schemas/resources/HeartbeatRequest.json
kafka/protocol/schemas/resources/HeartbeatResponse.json
kafka/protocol/schemas/resources/IncrementalAlterConfigsRequest.json
kafka/protocol/schemas/resources/IncrementalAlterConfigsResponse.json
kafka/protocol/schemas/resources/InitProducerIdRequest.json
kafka/protocol/schemas/resources/InitProducerIdResponse.json
kafka/protocol/schemas/resources/JoinGroupRequest.json
kafka/protocol/schemas/resources/JoinGroupResponse.json
kafka/protocol/schemas/resources/LeaveGroupRequest.json
kafka/protocol/schemas/resources/LeaveGroupResponse.json
kafka/protocol/schemas/resources/ListConfigResourcesRequest.json
kafka/protocol/schemas/resources/ListConfigResourcesResponse.json
kafka/protocol/schemas/resources/ListGroupsRequest.json
kafka/protocol/schemas/resources/ListGroupsResponse.json
kafka/protocol/schemas/resources/ListOffsetsRequest.json
kafka/protocol/schemas/resources/ListOffsetsResponse.json
kafka/protocol/schemas/resources/ListPartitionReassignmentsRequest.json
kafka/protocol/schemas/resources/ListPartitionReassignmentsResponse.json
kafka/protocol/schemas/resources/ListTransactionsRequest.json
kafka/protocol/schemas/resources/ListTransactionsResponse.json
kafka/protocol/schemas/resources/MetadataRequest.json
kafka/protocol/schemas/resources/MetadataResponse.json
kafka/protocol/schemas/resources/OffsetCommitRequest.json
kafka/protocol/schemas/resources/OffsetCommitResponse.json
kafka/protocol/schemas/resources/OffsetDeleteRequest.json
kafka/protocol/schemas/resources/OffsetDeleteResponse.json
kafka/protocol/schemas/resources/OffsetFetchRequest.json
kafka/protocol/schemas/resources/OffsetFetchResponse.json
kafka/protocol/schemas/resources/OffsetForLeaderEpochRequest.json
kafka/protocol/schemas/resources/OffsetForLeaderEpochResponse.json
kafka/protocol/schemas/resources/ProduceRequest.json
kafka/protocol/schemas/resources/ProduceResponse.json
kafka/protocol/schemas/resources/RequestHeader.json
kafka/protocol/schemas/resources/ResponseHeader.json
kafka/protocol/schemas/resources/SaslAuthenticateRequest.json
kafka/protocol/schemas/resources/SaslAuthenticateResponse.json
kafka/protocol/schemas/resources/SaslHandshakeRequest.json
kafka/protocol/schemas/resources/SaslHandshakeResponse.json
kafka/protocol/schemas/resources/SyncGroupRequest.json
kafka/protocol/schemas/resources/SyncGroupResponse.json
kafka/protocol/schemas/resources/TxnOffsetCommitRequest.json
kafka/protocol/schemas/resources/TxnOffsetCommitResponse.json
kafka/protocol/schemas/resources/UpdateFeaturesRequest.json
kafka/protocol/schemas/resources/UpdateFeaturesResponse.json
kafka/protocol/schemas/resources/WriteTxnMarkersRequest.json
kafka/protocol/schemas/resources/WriteTxnMarkersResponse.json
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/vendor/__init__.py
kafka_python.egg-info/PKG-INFO
kafka_python.egg-info/SOURCES.txt
kafka_python.egg-info/dependency_links.txt
kafka_python.egg-info/entry_points.txt
kafka_python.egg-info/requires.txt
kafka_python.egg-info/top_level.txt
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
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