summaryrefslogtreecommitdiff
path: root/test
Commit message (Expand)AuthorAgeFilesLines
* 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
* Use Popen.communicate() instead of Popen.wait()Brian Sang2019-01-051-9/+10
* Cleanup formatting, no functional changesJeff Widman2018-11-201-23/+23
* Be explicit with tuples for %s formattingJeff Widman2018-11-184-7/+7
* Migrate from `Unittest` to `pytest` (#1620)Jeff Widman2018-11-106-72/+34
* Cleanup fixture importsJeff Widman2018-10-277-15/+10
* Minor aesthetic cleanup of partitioner testsJeff Widman2018-10-271-11/+10
* Remove unused ivy_root variableJeff Widman2018-10-271-1/+0
* Add KafkaAdmin classRichard Lee2018-10-241-0/+47
* Vendor `six` consistentlyJeff Widman2018-10-2210-23/+23
* Fix typo in file nameJeff Widman2018-10-221-0/+0
* Support produce with Kafka record headersHeikki Nousiainen2018-09-271-1/+9
* Expose record headers in ConsumerRecordsHeikki Nousiainen2018-09-271-3/+3
* Add positive tests for headers in record encode/decodeHeikki Nousiainen2018-09-272-3/+18
* Don't use `kafka.common` internally1.3.5Jeff Widman2018-06-056-13/+14
* Ignore MetadataResponses with empty broker list (#1506)Dana Powers2018-05-261-0/+22
* Stop shadowing `ConnectionError`Jeff Widman2018-05-233-6/+6
* Skip flakey SimpleProducer testDana Powers2018-04-181-0/+1
* Add codec validators to record parser and builder for all formats (#1447)Taras2018-04-185-5/+96
* Fix MemoryRecord bugs re error handling and add test coverage (#1448)Taras2018-04-181-1/+68
* Change SimpleProducer to use async_send (async is reserved in py37) (#1454)Dana Powers2018-03-233-13/+13
* Fix skipped integration tests if KAFKA_VERSION unset (#1453)Dana Powers2018-03-222-0/+9
* Connect with sockaddrs to support non-zero ipv6 scope ids (#1433)Dana Powers2018-03-091-15/+12
* Add BrokerConnection.connect_blocking() (#1411)Dana Powers2018-03-092-3/+6
* Make BrokerConnection .host / .port / .afi immutable, use _sock_* attributes ...Dana Powers2018-03-091-9/+20
* Fix BrokerConnection.connection_delay() to return milliseconds (#1414)Dana Powers2018-03-081-0/+9
* Close KafkaConsumer instances during tests (#1410)Dana Powers2018-03-083-1/+11
View Lorry Controller Status