summaryrefslogtreecommitdiff
path: root/test
Commit message (Collapse)AuthorAgeFilesLines
* Use selectors module in KafkaClientselectorsDana Powers2016-04-091-1/+14
|
* Add state_change_callback to bootstrap connectionconn_state_callbackDana Powers2016-04-081-2/+8
|
* Move state logic from KafkaClient._maybe_connect to _conn_state_change as ↵Dana Powers2016-04-081-10/+24
| | | | callback
* Split test_ready to test_is_readyDana Powers2016-04-081-34/+21
|
* Speedup some failover tests w/ shorter SimpleClient timeoutDana Powers2016-04-081-1/+1
|
* Reduce batch time in producer integration test (speedup test)Dana Powers2016-04-081-2/+5
|
* Default sleep=True in client.pollDana Powers2016-04-081-4/+4
|
* Add BrokerConnection.disconnected() method; update testsDana Powers2016-04-082-8/+12
|
* Cleanup AF_INET import in conn fixturefrench_connectionDana Powers2016-04-071-1/+1
|
* Consolidate conn fixture definitionsDana Powers2016-04-074-42/+19
|
* Catch more producer exceptions in failover testsDana Powers2016-04-061-3/+6
|
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-056-63/+64
|
* KAFKA-3318: clean up consumer logging and error messagesDana Powers2016-04-051-3/+3
|
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-0516-58/+51
|
* Add BrokerConnection.send testsDana Powers2016-04-051-9/+102
|
* Merge pull request #589 from dpkp/node_not_readyDana Powers2016-04-043-283/+361
|\ | | | | Refactor NodeNotReadyError handling
| * Improve KafkaClient connect and ready handlingnode_not_readyDana Powers2016-04-041-44/+40
| | | | | | | | | | | | - merge _initiate and _finish into _maybe_connect - add connected(node_id) method - only short-circuit send() when not connected
| * Add basic unit test coverage for BrokerConnectionDana Powers2016-04-041-0/+82
| |
| * Move old KafkaConnection tests to test_conn_legacyDana Powers2016-04-041-0/+0
| |
* | Test _maybe_auto_commit_offsets_sync when group_id is NoneDana Powers2016-04-031-19/+35
|/
* Kafka IPv6 Support.Tim Evens2016-03-303-18/+37
| | | | | | IPv6 address without port can be defined as the IPv6 address. If the address is a hostname or if a port is included, then the address MUST be wrapped in brackets [] (E.g. [somehost]:1234 or [fd00:1001::2]:1234).
* Merge pull request #603 from dpkp/windowsDana Powers2016-03-241-0/+2
|\ | | | | Updates to support Windows
| * Skip test that fails on windowswindowsDana Powers2016-03-171-0/+2
| |
* | catch all errors thrown by _get_leader_for_partition in SimpleClientZack Dever2016-03-171-3/+3
| |
* | KAFKA-2698: add paused APIZack Dever2016-03-161-5/+25
|/
* join consumer threads in test_consumer_group cleanupDana Powers2016-03-141-2/+4
|
* Re-render fixture config in restart loop if necessaryDana Powers2016-03-141-0/+10
|
* More fixture logging improvementsDana Powers2016-03-144-14/+19
| | | | | | | | - Add test logging NullHandler - Remove default logging level filtering in testutil - Log render_template info - More fixture logging cleanups - wait_for() should not handle child shutdown
* Fixup test fixtures for pylintDana Powers2016-03-132-1/+11
|
* Merge pull request #585 from dpkp/truncate_bufferDana Powers2016-03-131-5/+22
|\ | | | | Truncate deallocated message buffers
| * Reduce end-to-end test to 100 messages; raise produce future exceptions ↵Dana Powers2016-03-131-5/+9
| | | | | | | | immediately
| * Add SimpleBufferPool test to verify reallocated buffers are emptyDana Powers2016-03-131-0/+13
| |
* | Improve Fixture loggingDana Powers2016-03-132-31/+19
|/ | | | | | | - remove double console appenders from log4j.properties - also log to server.log file for interactive uses - drop internal _spawn from SpawnedService loop - write captured stdout/stderr directly to avoid logger re-formatting
* Use producer retries and flush timeout in producer end-to-end testDana Powers2016-03-131-1/+2
|
* Move logging format config to tox.ini to avoid duplicate log capture in ↵Dana Powers2016-03-131-2/+0
| | | | pytest output
* Add heartbeat timeout testDana Powers2016-03-121-3/+24
|
* Add test for unknown coordinator heartbeat taskDana Powers2016-03-121-2/+14
|
* Add timestamps to basic test loggingDana Powers2016-03-121-1/+2
|
* Sync rendered fixture templates to disk to avoid racesDana Powers2016-03-121-0/+8
|
* Improve Zookeeper / Kafka Fixture managementDana Powers2016-03-122-4/+22
| | | | | | - spawn fixtures via daemon threads - close fixtures atexit and in __del__ to avoid interpreter hangs - raise Exception on timeouts in open()
* Mock client.ready() call to test coordinator offset fetch requestDana Powers2016-02-191-0/+1
|
* break up some circular references and close client wake pipe on __del__aisch2016-02-161-1/+2
|
* Add RangePartitionAssignor (and use as default); add assignor testsrange_assignorDana Powers2016-02-162-7/+69
|
* Make sure all consumers are in same generation before stopping group testDana Powers2016-02-161-0/+13
|
* Support setting kafka instance port explicitly in fixtureDana Powers2016-02-153-7/+16
|
* Mark old kafka.common structs as Deprecated; remove unused TopicMetadataDana Powers2016-02-151-5/+8
|
* Fix missing importDana Powers2016-01-301-0/+1
|
* Skip MultiProcessConsumer integration testsDana Powers2016-01-301-0/+5
|
* Handle broken LZ4 framing; switch to lz4tools + xxhashlz4_fixupDana Powers2016-01-261-3/+9
|
* Add end-to-end integration testing for all compression typesDana Powers2016-01-261-1/+8
|
View Lorry Controller Status