.appveyor.yml .codecov.yml .github/ISSUE_TEMPLATE/bug_report.md .github/ISSUE_TEMPLATE/feature_request.md .github/ISSUE_TEMPLATE/question.md .github/pull_request_template.md .github/workflows/publish.yml .github/workflows/tests.yml .gitignore .pyup.yml .travis.yml_bak CHANGES.rst CHANGES/566.doc LICENSE MANIFEST.in Makefile README.rst aiokafka/__init__.py aiokafka/abc.py aiokafka/client.py aiokafka/cluster.py aiokafka/conn.py aiokafka/consumer/__init__.py aiokafka/consumer/consumer.py aiokafka/consumer/fetcher.py aiokafka/consumer/group_coordinator.py aiokafka/consumer/subscription_state.py aiokafka/errors.py aiokafka/helpers.py aiokafka/producer/__init__.py aiokafka/producer/message_accumulator.py aiokafka/producer/producer.py aiokafka/producer/sender.py aiokafka/producer/transaction_manager.py aiokafka/protocol/coordination.py aiokafka/protocol/fetch.py aiokafka/protocol/produce.py aiokafka/protocol/transaction.py aiokafka/record/__init__.py aiokafka/record/_crc32c.py aiokafka/record/_crecords/__init__.py aiokafka/record/_crecords/consts.pxi aiokafka/record/_crecords/crc32c.c aiokafka/record/_crecords/crc32c.h aiokafka/record/_crecords/cutil.pxd aiokafka/record/_crecords/cutil.pyx aiokafka/record/_crecords/default_records.pxd aiokafka/record/_crecords/default_records.pyx aiokafka/record/_crecords/hton.pxd aiokafka/record/_crecords/legacy_records.pxd aiokafka/record/_crecords/legacy_records.pyx aiokafka/record/_crecords/memory_records.pyx aiokafka/record/control_record.py aiokafka/record/default_records.py aiokafka/record/legacy_records.py aiokafka/record/memory_records.py aiokafka/record/util.py aiokafka/structs.py aiokafka/util.py benchmark/README benchmark/record_batch_compose.py benchmark/record_batch_read.py benchmark/simple_consume_bench.py benchmark/simple_produce_bench.py docker/Dockerfile docker/Makefile docker/README.rst docker/build.py docker/config.yml docker/scripts/kafka_server_gssapi_jaas.conf docker/scripts/kafka_server_jaas.conf docker/scripts/kafka_server_jaas_no_scram.conf docker/scripts/krb5.conf docker/scripts/start-kafka.sh docker/supervisor/kafka.conf docker/supervisor/kdc.conf docker/supervisor/zookeeper.conf docs/Makefile docs/_static/custom.css docs/api.rst docs/conf.py docs/consumer.rst docs/examples.rst docs/examples/batch_produce.rst docs/examples/custom_partitioner.rst docs/examples/group_consumer.rst docs/examples/local_state_consumer.rst docs/examples/manual_commit.rst docs/examples/python35_examples.rst docs/examples/serialize_and_compress.rst docs/examples/ssl_consume_produce.rst docs/examples/transaction_example.rst docs/index.rst docs/kafka-python_difference.rst docs/producer.rst dump_pem.py examples/batch_produce.py examples/indempotent_produce.py examples/local_state_consumer.py examples/simple_consumer-3.5.py examples/simple_consumer.py examples/simple_produce.py examples/ssl_consume_produce.py examples/transactional_produce.py gen-ssl-certs.sh pytest.ini requirements-ci.txt requirements-cython.txt requirements-dev.txt requirements-docs.txt requirements-win-test.txt setup.cfg setup.py stubs/kafka/__init__.pyi stubs/kafka/admin/__init__.pyi stubs/kafka/admin/acl_resource.pyi stubs/kafka/admin/client.pyi stubs/kafka/admin/config_resource.pyi stubs/kafka/admin/new_partitions.pyi stubs/kafka/admin/new_topic.pyi stubs/kafka/client_async.pyi stubs/kafka/cluster.pyi stubs/kafka/codec.pyi stubs/kafka/conn.pyi stubs/kafka/consumer/__init__.pyi stubs/kafka/consumer/fetcher.pyi stubs/kafka/consumer/group.pyi stubs/kafka/consumer/subscription_state.pyi stubs/kafka/coordinator/__init__.pyi stubs/kafka/coordinator/assignors/__init__.pyi stubs/kafka/coordinator/assignors/abstract.pyi stubs/kafka/coordinator/assignors/range.pyi stubs/kafka/coordinator/assignors/roundrobin.pyi stubs/kafka/coordinator/base.pyi stubs/kafka/coordinator/consumer.pyi stubs/kafka/coordinator/heartbeat.pyi stubs/kafka/coordinator/protocol.pyi stubs/kafka/errors.pyi stubs/kafka/future.pyi stubs/kafka/metrics/__init__.pyi stubs/kafka/metrics/compound_stat.pyi stubs/kafka/metrics/dict_reporter.pyi stubs/kafka/metrics/kafka_metric.pyi stubs/kafka/metrics/measurable.pyi stubs/kafka/metrics/measurable_stat.pyi stubs/kafka/metrics/metric_config.pyi stubs/kafka/metrics/metric_name.pyi stubs/kafka/metrics/metrics.pyi stubs/kafka/metrics/metrics_reporter.pyi stubs/kafka/metrics/quota.pyi stubs/kafka/metrics/stat.pyi stubs/kafka/metrics/stats/__init__.pyi stubs/kafka/metrics/stats/avg.pyi stubs/kafka/metrics/stats/count.pyi stubs/kafka/metrics/stats/histogram.pyi stubs/kafka/metrics/stats/max_stat.pyi stubs/kafka/metrics/stats/min_stat.pyi stubs/kafka/metrics/stats/percentile.pyi stubs/kafka/metrics/stats/percentiles.pyi stubs/kafka/metrics/stats/rate.pyi stubs/kafka/metrics/stats/sampled_stat.pyi stubs/kafka/metrics/stats/sensor.pyi stubs/kafka/metrics/stats/total.pyi stubs/kafka/oauth/__init__.pyi stubs/kafka/oauth/abstract.pyi stubs/kafka/partitioner/__init__.pyi stubs/kafka/partitioner/default.pyi stubs/kafka/producer/__init__.pyi stubs/kafka/producer/buffer.pyi stubs/kafka/producer/future.pyi stubs/kafka/producer/kafka.pyi stubs/kafka/producer/record_accumulator.pyi stubs/kafka/producer/sender.pyi stubs/kafka/protocol/__init__.pyi stubs/kafka/protocol/abstract.pyi stubs/kafka/protocol/admin.pyi stubs/kafka/protocol/api.pyi stubs/kafka/protocol/commit.pyi stubs/kafka/protocol/fetch.pyi stubs/kafka/protocol/frame.pyi stubs/kafka/protocol/group.pyi stubs/kafka/protocol/message.pyi stubs/kafka/protocol/metadata.pyi stubs/kafka/protocol/offset.pyi stubs/kafka/protocol/parser.pyi stubs/kafka/protocol/pickle.pyi stubs/kafka/protocol/produce.pyi stubs/kafka/protocol/struct.pyi stubs/kafka/protocol/types.pyi stubs/kafka/record/__init__.pyi stubs/kafka/record/_crc32c.pyi stubs/kafka/record/abc.pyi stubs/kafka/record/default_records.pyi stubs/kafka/record/legacy_records.pyi stubs/kafka/record/memory_records.pyi stubs/kafka/record/util.pyi stubs/kafka/scram.pyi stubs/kafka/serializer/__init__.pyi stubs/kafka/serializer/abstract.pyi stubs/kafka/structs.pyi stubs/kafka/util.pyi stubs/kafka/version.pyi tests/__init__.py tests/_testutil.py tests/conftest.py tests/record/test_control_record.py tests/record/test_default_records.py tests/record/test_legacy.py tests/record/test_records.py tests/record/test_util.py tests/test_client.py tests/test_conn.py tests/test_consumer.py tests/test_coordinator.py tests/test_fetcher.py tests/test_helpers.py tests/test_message_accumulator.py tests/test_pep492.py tests/test_producer.py tests/test_sasl.py tests/test_sender.py tests/test_subscription_state.py tests/test_transaction_manager.py tests/test_transactional_consumer.py tests/test_transactional_producer.py tools/README tools/python_snappy-0.5.4-cp36-cp36m-win32.whl tools/python_snappy-0.5.4-cp36-cp36m-win_amd64.whl tools/python_snappy-0.5.4-cp37-cp37m-win32.whl tools/python_snappy-0.5.4-cp37-cp37m-win_amd64.whl tools/python_snappy-0.5.4-cp38-cp38-win_amd64.whl tools/python_snappy-0.5.4-cp38-cp38m-win32.whl tools/python_snappy-0.5.4-cp38-cp38m-win_amd64.whl <<<<<< network # path=coverage-no-extension.xml C:\projects\aiokafka\aiokafka <<<<<< EOF