summaryrefslogtreecommitdiff
path: root/test
Commit message (Collapse)AuthorAgeFilesLines
* Cleanup formatting, no functional changesJeff Widman2018-11-201-23/+23
| | | | Cleanup the formatting, remove parens, extraneous spaces, etc.
* Be explicit with tuples for %s formattingJeff Widman2018-11-184-7/+7
| | | | Fix #1633
* Migrate from `Unittest` to `pytest` (#1620)Jeff Widman2018-11-106-72/+34
|
* Cleanup fixture importsJeff Widman2018-10-277-15/+10
| | | | | | | | | | | | | | | `random_string` now comes from `test.fixtures` and was being transparently imported via `test.testutil` so this bypasses the pointless indirect import. Similarly, `kafka_version` was transparently imported by `test.testutil` from `test.fixtures`. Also removed `random_port()` in `test.testutil` because its unused as its been replaced by the one in `test.fixtures`. This is part of the pytest migration that was started back in a1869c4be5f47b4f6433610249aaf29af4ec95e5.
* Minor aesthetic cleanup of partitioner testsJeff Widman2018-10-271-11/+10
|
* Remove unused ivy_root variableJeff Widman2018-10-271-1/+0
| | | | This is no longer used anywhere in the codebase
* Add KafkaAdmin classRichard Lee2018-10-241-0/+47
| | | | | | Requires cluster version > 0.10.0.0, and uses new wire protocol classes to do many things via broker connection that previously needed to be done directly in zookeeper.
* Vendor `six` consistentlyJeff Widman2018-10-2210-23/+23
| | | | Use vendored `six`, and also `six.moves.range` rather than `xrange`
* 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
| | | | This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`.
* Ignore MetadataResponses with empty broker list (#1506)Dana Powers2018-05-261-0/+22
|
* Stop shadowing `ConnectionError`Jeff Widman2018-05-233-6/+6
| | | | | | | | | | In Python3, `ConnectionError` is a native exception. So rename our custom one to `KafkaConnectionError` to prevent accidentally shadowing the native one. Note that there are still valid uses of `ConnectionError` in this code. They already expect a native Python3 `ConnectionError`, and also already handle the Python2 compatibility issues.
* 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
| | | | for current lookups (#1422)
* 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
|
* Fix KafkaConsumer compacted offset handling (#1397)Dana Powers2018-02-261-2/+19
|
* Fixes racing condition when message is sent to broker before topic logs are ↵Andre Araujo2018-02-211-3/+19
| | | | created
* Introduce new fixtures to prepare for migration to pytest.Andre Araujo2018-02-217-157/+458
| | | | | | | This commits adds new pytest fixtures in prepation for the migration of unittest.TestCases to pytest test cases. The handling of temporary dir creation was also changed so that we can use the pytest tmpdir fixture after the migration.
* Use hardware accelerated CRC32C function if available (#1389)Taras Voinarovskyi2018-02-211-2/+3
| | | | | | * Use hardware accelerated CRC32C function if available * Add doc notice of optional `crc32c` package
* Increase some integration test timeouts (#1374)Dana Powers2018-02-084-10/+24
|
* Avoid consuming duplicate compressed messages from mid-batch (#1367)Dana Powers2018-02-051-0/+40
|
* KAFKA-3949: Avoid race condition when subscription changes during rebalance ↵Dana Powers2018-02-021-37/+21
| | | | (#1364)
* Use 0.11.0.2 kafka broker for integration testing (#1357)Dana Powers2018-01-251-1/+1
|
* Minor test cleanups (#1343)Dana Powers2018-01-123-2/+5
|
* Honor reconnect_backoff in conn.connect() (#1342)Dana Powers2018-01-111-0/+2
| | | * Honor reconnect_backoff in conn.connect()
* Fix coordinator join_future race condition (#1338)Dana Powers2018-01-111-0/+13
| | | * Fix race condition in coordinator join_future handling
* KAFKA-3888 Use background thread to process consumer heartbeats (#1266)Dana Powers2017-12-215-56/+107
|
* Minor Exception cleanupJeff Widman2017-12-123-4/+4
|
* Refactor dns lookup in BrokerConnection (#1312)Dana Powers2017-12-081-0/+25
|
* Change fixture default host to localhost (#1305)Andre Araujo2017-12-051-15/+1
|
* Revert ffc7caef13a120f69788bcdd43ffa01468f575f9 / PR #1239Dana Powers2017-11-161-23/+0
| | | | The change caused a regression documented in issue #1290
* Handle lookup_coordinator send failures (#1279)Dana Powers2017-10-241-0/+8
|
* Add DefaultRecordBatch implementation aka V2 message format parser/builder. ↵Taras Voinarovskyi2017-10-255-6/+315
| | | | | (#1185) Added bytecode optimization for varint and append/read_msg functions. Mostly based on avoiding LOAD_GLOBAL calls.
* Add fixture support for upcoming 1.0.0 broker release (#1275)Dana Powers2017-10-231-2/+6
|
* Fix timestamp not passed to RecordMetadata (#1273)Taras Voinarovskyi2017-10-222-8/+139
| | | | | | | | * Fix timestamp not being passed to RecordMetadata properly * Add more tests for LegacyBatch * Fix producer test for recordmetadata
* Move callback processing from BrokerConnection to KafkaClientpending_completionsDana Powers2017-10-151-1/+2
|
* Merge pull request #1252 from dpkp/legacy_records_refactorTaras Voinarovskyi2017-10-147-180/+236
|\ | | | | Refactor MessageSet and Message into LegacyRecordBatch
| * Fix tests and rebase problemsTaras2017-10-121-95/+27
| |
| * Refactor MessageSet and Message into LegacyRecordBatch to later support v2 ↵Taras2017-10-116-85/+209
| | | | | | | | message format
* | KAFKA-4034: Avoid unnecessary consumer coordinator lookup (#1254)Dana Powers2017-10-111-5/+4
|/
View Lorry Controller Status