Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Generate SSL certificates for local testing (#1756) | Dana Powers | 2019-03-21 | 1 | -0/+29 |
| | | | This doesn't fully implement SSL fixtures, but as a first step it should help with automatically generating required certificates / keystores / etc. My hope is that this helps generate more community support for SSL testing! | ||||
* | Do network connections and writes in KafkaClient.poll() (#1729) | Dana Powers | 2019-03-08 | 1 | -3/+4 |
| | | | | | | * Add BrokerConnection.send_pending_requests to support async network sends * Send network requests during KafkaClient.poll() rather than in KafkaClient.send() * Dont acquire lock during KafkaClient.send if node is connected / ready * Move all network connection IO into KafkaClient.poll() | ||||
* | Use Popen.communicate() instead of Popen.wait() | Brian Sang | 2019-01-05 | 1 | -9/+10 |
| | | | | | Popen objects may deadlock when using stdout=PIPE or stderr=PIPE with Popen.wait(). Using Popen.communicate() avoids the issue. | ||||
* | Be explicit with tuples for %s formatting | Jeff Widman | 2018-11-18 | 1 | -4/+4 |
| | | | | Fix #1633 | ||||
* | Remove unused ivy_root variable | Jeff Widman | 2018-10-27 | 1 | -1/+0 |
| | | | | This is no longer used anywhere in the codebase | ||||
* | Vendor `six` consistently | Jeff Widman | 2018-10-22 | 1 | -3/+3 |
| | | | | Use vendored `six`, and also `six.moves.range` rather than `xrange` | ||||
* | Introduce new fixtures to prepare for migration to pytest. | Andre Araujo | 2018-02-21 | 1 | -62/+237 |
| | | | | | | | 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. | ||||
* | Increase some integration test timeouts (#1374) | Dana Powers | 2018-02-08 | 1 | -2/+4 |
| | |||||
* | Use 0.11.0.2 kafka broker for integration testing (#1357) | Dana Powers | 2018-01-25 | 1 | -1/+1 |
| | |||||
* | Minor Exception cleanup | Jeff Widman | 2017-12-12 | 1 | -2/+2 |
| | |||||
* | Change fixture default host to localhost (#1305) | Andre Araujo | 2017-12-05 | 1 | -15/+1 |
| | |||||
* | Add fixture support for upcoming 1.0.0 broker release (#1275) | Dana Powers | 2017-10-23 | 1 | -2/+6 |
| | |||||
* | Update to 0.11.0.1 for travis test fixture; use as default if unspecified ↵ | Dana Powers | 2017-10-08 | 1 | -1/+1 |
| | | | | (#1244) | ||||
* | Dump fixture logs on failure | Dana Powers | 2016-08-04 | 1 | -0/+2 |
| | |||||
* | Try to bind to a new port on fixture failure retries | Dana Powers | 2016-08-04 | 1 | -29/+21 |
| | |||||
* | Always absolute_importabsolute_import | Dana Powers | 2016-08-02 | 1 | -0/+2 |
| | |||||
* | Allow setting host interface in KafkaFixture.instance | Dana Powers | 2016-04-25 | 1 | -2/+4 |
| | |||||
* | More thorough IPv6 support that uses getaddrinfo to resolve names | James Brown | 2016-04-24 | 1 | -2/+16 |
| | | | | Fixes #641 | ||||
* | Attempt to add ssl support to kafka fixturesssl_support | Dana Powers | 2016-04-09 | 1 | -4/+10 |
| | |||||
* | Re-render fixture config in restart loop if necessary | Dana Powers | 2016-03-14 | 1 | -0/+10 |
| | |||||
* | More fixture logging improvements | Dana Powers | 2016-03-14 | 1 | -7/+8 |
| | | | | | | | | - 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 pylint | Dana Powers | 2016-03-13 | 1 | -1/+10 |
| | |||||
* | Improve Fixture logging | Dana Powers | 2016-03-13 | 1 | -3/+7 |
| | | | | | | | - 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 | ||||
* | Sync rendered fixture templates to disk to avoid races | Dana Powers | 2016-03-12 | 1 | -0/+8 |
| | |||||
* | Improve Zookeeper / Kafka Fixture management | Dana Powers | 2016-03-12 | 1 | -4/+21 |
| | | | | | | - spawn fixtures via daemon threads - close fixtures atexit and in __del__ to avoid interpreter hangs - raise Exception on timeouts in open() | ||||
* | Support setting kafka instance port explicitly in fixture | Dana Powers | 2016-02-15 | 1 | -3/+7 |
| | |||||
* | Move pytest broker/zk fixtures to test.conftest | Dana Powers | 2016-01-24 | 1 | -1/+2 |
| | |||||
* | pylint fixes | Dana Powers | 2015-12-10 | 1 | -1/+1 |
| | | | | | | - temporarily ignore kafka/consumer/group.py - temporarily ignore test/test_protocol.py - disable-msg deprecated; use disable= instead | ||||
* | new pylint disables for pylint 1.5.1 | Zack Dever | 2015-12-02 | 1 | -1/+1 |
| | | | | | tested locally with `pylint --rcfile=pylint.rc -E kafka test`. should pass travis builds. | ||||
* | Increase timeout and backoff when retrying spawn of test fixtures | Dana Powers | 2015-06-11 | 1 | -2/+16 |
| | |||||
* | Create a new child thread on each open fixture try | Dana Powers | 2015-06-09 | 1 | -6/+7 |
| | |||||
* | Retry with shorter 5sec timeout when trying to open() fixtures | Dana Powers | 2015-06-08 | 1 | -4/+10 |
| | | | | | - this is intended to reduce flapping tests caused by intermittent - fixture startup issues on travis-ci | ||||
* | Module loggers in test/fixtures and test/service | Dana Powers | 2015-06-06 | 1 | -19/+23 |
| | |||||
* | Change ZookeeperFixture wait_for regex to support newer zk version used with ↵ | Dana Powers | 2015-01-14 | 1 | -1/+1 |
| | | | | 0.8.2.0 | ||||
* | Fix KafkaFixture child stdout / stderr capture | Dana Powers | 2015-01-14 | 1 | -2/+2 |
| | |||||
* | Make all unit tests pass on py3.3/3.4 | Bruno Renié | 2014-09-03 | 1 | -5/+5 |
| | |||||
* | Add pylint to tox.ini; test both kafka and test; default to error-checking ↵ | Dana Powers | 2014-08-25 | 1 | -27/+22 |
| | | | | only; fixup errors; skip kafka/queue.py | ||||
* | Add kafka 0.8.1.1 to integration tests. | Dana Powers | 2014-08-13 | 1 | -15/+0 |
| | | | | | | - previous 0.8.1 src appears to have actually been 0.8.1.1 based on git submodule commit. So technically this adds back 0.8.1 to the test suite. | ||||
* | Use kafka_run_class_env() to set environment vars in test fixtures | Dana Powers | 2014-08-12 | 1 | -16/+14 |
| | |||||
* | Download official binaries from apache.org for integration tests | Dana Powers | 2014-08-12 | 1 | -1/+5 |
| | |||||
* | Add Fixtures.download_official_distribution to get binaries from apache.org | Dana Powers | 2014-08-12 | 1 | -0/+39 |
| | |||||
* | Attempt to fix travis build. Decrease complexity of service.py in favor of ↵ | Mark Roberts | 2014-05-06 | 1 | -4/+0 |
| | | | | in memory logging. Address code review concerns | ||||
* | Add test support for multiple versions of kafka. Uncomment first 0.8.1 ↵ | Mark Roberts | 2014-04-23 | 1 | -2/+2 |
| | | | | specific test. Add rudimentary (failing) consumer resumption test | ||||
* | Add support for kafka 0.8.1 | Mark Roberts | 2014-04-23 | 1 | -1/+5 |
| | |||||
* | Move kafka-src to servers/0.8.0/kafka-src, move test/resources to ↵ | Mark Roberts | 2014-04-23 | 1 | -3/+4 |
| | | | | servers/0.8.0/resources, update fixtures, add build_integration.sh for getting started with development | ||||
* | Update fixtures to eliminate extraneous logging on non-errors, split out ↵ | Mark Roberts | 2014-04-22 | 1 | -215/+85 |
| | | | | mostly unrelated service.py, fix test in client_integration to use get_open_port, fix unintended import cascade in test_producer_integration | ||||
* | Some cleanup and easier to read test fixture output | Omar Ghishan | 2014-01-07 | 1 | -4/+4 |
| | |||||
* | Add object type and ID to message prefix in fixtures output for easier debugging | Omar Ghishan | 2014-01-06 | 1 | -15/+21 |
| | |||||
* | Handle starting/stopping Kafka brokers that are already started/stopped in ↵ | Omar Ghishan | 2014-01-06 | 1 | -0/+11 |
| | | | | | | | integration tests If some of the tests stop brokers then error out, the teardown method will try to close the same brokers and fail. This change allows it to continue. | ||||
* | Set host and port in ExternalService test fixture | David Arthur | 2013-11-11 | 1 | -0/+2 |
| | | | | | So we can run tests against an already running Kafka instance KAFKA_URI=tcp://localhost:9092 python -m test.test_integration |