summaryrefslogtreecommitdiff
path: root/test
Commit message (Expand)AuthorAgeFilesLines
* Core Protocol: Add support for flexible versions (#2151)Tincu Gabriel2020-12-021-1/+53
* Cover sticky assignor's metadata method with tests (#2161)Valeria Chernenko2020-11-051-42/+33
* KIP-54: Implement sticky partition assignment strategy (#2057)Valeria Chernenko2020-09-293-19/+883
* Feature: delete consumergroups (#2040)Swen Wenzel2020-09-171-1/+77
* Enhancement for Kafka Admin Client's "Describe Consumer Group" (#2035)Apurva0072020-09-161-2/+100
* Add support for `zstd` compression (#2021)Tincu Gabriel2020-09-072-11/+20
* Add logic for inferring newer broker versions (#2038)Tincu Gabriel2020-05-051-3/+12
* Implement methods to convert a Struct object to a pythonic object (#1951)Tyler Lubeck2020-02-061-0/+236
* Use ==/!= to compare str, bytes, and int literalsChristian Clauss2020-02-051-1/+1
* Optionally return OffsetAndMetadata from consumer.committed(tp) (#1979)Dana Powers2019-12-292-4/+4
* Implement __eq__ and __hash__ for ACL objects (#1955)Tyler Lubeck2019-12-291-0/+92
* Admin protocol updates (#1948)Tyler Lubeck2019-12-291-0/+18
* Style updates to scram sasl supportDana Powers2019-12-291-4/+6
* Enable SCRAM-SHA-256 and SCRAM-SHA-512 for sasl (#1918)Swen Wenzel2019-12-295-89/+323
* xfail test_describe_configs_topic_resource_returns_configs (Issue #1929)Dana Powers2019-12-281-0/+3
* Fix typosCarson Ip2019-11-081-1/+1
* Remove SimpleClient, Producer, Consumer, Unittest (#1196)Jeff Widman2019-10-1116-3375/+19
* Fix describe config for multi-broker clusters (#1869)Jeppe Andersen2019-10-111-1/+56
* convert test_admin_integration to pytest (#1923)Ulrik Johansson2019-10-073-103/+90
* Add KAFKA 2.3.0 to test matrix (#1915)Dana Powers2019-09-302-2/+8
* Follow up to PR 1782 -- fix tests (#1914)Dana Powers2019-09-301-3/+2
* Issue #1780 - Consumer hang indefinitely in fetcher._retrieve_offsets() due t...Commander Dishwasher2019-09-301-4/+0
* Send socket data via non-blocking IO with send buffer (#1912)Dana Powers2019-09-291-1/+3
* Do not use wakeup when sending fetch requests from consumer (#1911)Dana Powers2019-09-291-1/+1
* Rely on socket selector to detect completed connection attempts (#1909)Dana Powers2019-09-282-2/+2
* Skip admin integration tests -- travis fixture issuesDana Powers2019-09-281-4/+7
* Fix Admin Client api version checking; only test ACL integration on 0.11+Dana Powers2019-09-281-5/+8
* Fixup test_admin_integration test fixturesDana Powers2019-09-281-5/+14
* Add ACL api to KafkaAdminClient (#1833)Ulrik Johansson2019-09-282-0/+138
* Convert remaining `KafkaConsumer` tests to `pytest` (#1886)Jeff Widman2019-08-224-256/+284
* Cleanup handling of KAFKA_VERSION env var in tests (#1887)Jeff Widman2019-08-2210-142/+65
* Minor test cleanup (#1885)Jeff Widman2019-08-218-11/+25
* tests: Use socket.SOCK_STREAM in assertionsIvan A. Melnikov2019-08-151-4/+4
* Sanity test for consumer.topics() and consumer.partitions_for_topic()Brian Sang2019-06-041-0/+9
* Reduce client poll timeout when no ifrsDana Powers2019-05-291-0/+12
* Update docs for api_version_auto_timeout_ms (#1812)Jeff Widman2019-05-242-5/+27
* Remove unused imports (#1808)Jeff Widman2019-05-221-5/+1
* Do not call state_change_callback with lock (#1775)Dana Powers2019-04-021-10/+11
* Dont treat popped conn.close() as failure in state change callback (#1773)Dana Powers2019-04-011-2/+3
* Dont wakeup during maybe_refresh_metadata -- it is only called by poll() (#1769)Dana Powers2019-03-301-2/+2
* Fix flaky conn tests that use time.time (#1758)Dana Powers2019-03-211-9/+12
* Generate SSL certificates for local testing (#1756)Dana Powers2019-03-211-0/+29
* Error if connections_max_idle_ms not larger than request_timeout_ms (#1688)Jeff Widman2019-03-141-2/+6
* Retry bootstrapping after backoff when necessary (#1736)Dana Powers2019-03-141-45/+23
* Mock dns lookups in test_conn (#1739)Dana Powers2019-03-131-1/+8
* Recheck connecting nodes sooner when refreshing metadata (#1737)Dana Powers2019-03-131-1/+1
* Synchronize puts to KafkaConsumer protocol buffer during async sendsDana Powers2019-03-121-4/+24
* Do network connections and writes in KafkaClient.poll() (#1729)Dana Powers2019-03-082-8/+8
* Use test.fixtures.version not test.conftest.version to avoid warnings (#1731)Dana Powers2019-03-064-8/+4
* Fix test_legacy_correct_metadata_response on x86 arch (#1718)Stanislav Levin2019-02-211-1/+1