The Wayback Machine - https://web.archive.org/web/20211029015746/https://github.com/dpkp/kafka-python/tree/master/test
Skip to content
master
Switch branches/tags
kafka-python/test/
Go to file
kafka-python/test/

Latest commit

Tincu Gabriel Core Protocol: Add support for flexible versions (#2151)
9feeb79 Dec 2, 2020
Core Protocol: Add support for flexible versions (#2151) 
- Add support for new request and response headers, supporting flexible
versions / tagged fields
- Add List / Alter partition reassignments APIs
- Add support for varints
- Add support for compact collections (byte array, string, array)
9feeb79

Git stats

Files

Permalink
Failed to load latest commit information.
Type
Name
Latest commit message
Commit time
. .
record
Fix typos
Nov 8, 2019
__init__.py
Enable SCRAM-SHA-256 and SCRAM-SHA-512 for sasl (#1918)
Dec 29, 2019
conftest.py
Remove SimpleClient, Producer, Consumer, Unittest (#1196)
Oct 11, 2019
fixtures.py
Style updates to scram sasl support
Dec 29, 2019
service.py
Enable SCRAM-SHA-256 and SCRAM-SHA-512 for sasl (#1918)
Dec 29, 2019
test_acl_comparisons.py
Implement __eq__ and __hash__ for ACL objects (#1955)
Dec 29, 2019
test_admin.py
Add ACL api to KafkaAdminClient (#1833)
Sep 28, 2019
test_admin_integration.py
Feature: delete consumergroups (#2040)
Sep 17, 2020
test_api_object_implementation.py
Admin protocol updates (#1948)
Dec 29, 2019
test_assignors.py
Cover sticky assignor's metadata method with tests (#2161)
Nov 6, 2020
test_client_async.py
Send socket data via non-blocking IO with send buffer (#1912)
Sep 30, 2019
test_cluster.py
Ignore MetadataResponses with empty broker list (#1506)
May 26, 2018
test_codec.py
Add support for zstd compression (#2021)
Sep 7, 2020
test_conn.py
Rely on socket selector to detect completed connection attempts (#1909)
Sep 29, 2019
test_consumer.py
Remove SimpleClient, Producer, Consumer, Unittest (#1196)
Oct 11, 2019
test_consumer_group.py
Convert remaining KafkaConsumer tests to pytest (#1886)
Aug 23, 2019
test_consumer_integration.py
Add logic for inferring newer broker versions (#2038)
May 5, 2020
test_coordinator.py
KIP-54: Implement sticky partition assignment strategy (#2057)
Sep 30, 2020
test_fetcher.py
Optionally return OffsetAndMetadata from consumer.committed(tp) (#1979)
Dec 30, 2019
test_metrics.py
Be explicit with tuples for %s formatting
Nov 18, 2018
test_object_conversion.py
Implement methods to convert a Struct object to a pythonic object (#1951
Feb 6, 2020
test_package.py
Remove SimpleClient, Producer, Consumer, Unittest (#1196)
Oct 11, 2019
test_partition_movements.py
KIP-54: Implement sticky partition assignment strategy (#2057)
Sep 30, 2020
test_partitioner.py
Remove SimpleClient, Producer, Consumer, Unittest (#1196)
Oct 11, 2019
test_producer.py
Add support for zstd compression (#2021)
Sep 7, 2020
test_protocol.py
Core Protocol: Add support for flexible versions (#2151)
Dec 2, 2020
test_sasl_integration.py
Enable SCRAM-SHA-256 and SCRAM-SHA-512 for sasl (#1918)
Dec 29, 2019
test_sender.py
Refactor MessageSet and Message into LegacyRecordBatch to later suppo…
Oct 11, 2017
test_subscription_state.py
Fix typo in file name
Oct 22, 2018
testutil.py
Enable SCRAM-SHA-256 and SCRAM-SHA-512 for sasl (#1918)
Dec 29, 2019