Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Style updates to scram sasl support | Dana Powers | 2019-12-29 | 1 | -4/+6 |
| | |||||
* | Enable SCRAM-SHA-256 and SCRAM-SHA-512 for sasl (#1918) | Swen Wenzel | 2019-12-29 | 1 | -76/+222 |
| | |||||
* | Remove SimpleClient, Producer, Consumer, Unittest (#1196) | Jeff Widman | 2019-10-11 | 1 | -6/+1 |
| | | | | | | | | | | | | | | | | | | In the 2.0 release, we're removing: * `SimpleClient` * `SimpleConsumer` * `SimpleProducer` * Old partitioners used by `SimpleProducer`; these are superceded by the `DefaultPartitioner` These have been deprecated for several years in favor of `KafkaClient` / `KafkaConsumer` / `KafkaProducer`. Since 2.0 allows breaking changes, we are removing the deprecated classes. Additionally, since the only usage of `unittest` was in tests for these old Simple* clients, this also drops `unittest` from the library. All tests now run under `pytest`. | ||||
* | convert test_admin_integration to pytest (#1923) | Ulrik Johansson | 2019-10-07 | 1 | -1/+9 |
| | |||||
* | Cleanup handling of KAFKA_VERSION env var in tests (#1887) | Jeff Widman | 2019-08-22 | 1 | -22/+3 |
| | | | | | | | | | | | | | Now that we are using `pytest`, there is no need for a custom decorator because we can use `pytest.mark.skipif()`. This makes the code significantly simpler. In particular, dropping the custom `@kafka_versions()` decorator is necessary because it uses `func.wraps()` which doesn't play nice with `pytest` fixtures: - https://github.com/pytest-dev/pytest/issues/677 - https://stackoverflow.com/a/19614807/770425 So this is a pre-requisite to migrating some of those tests to using pytest fixtures. | ||||
* | Minor test cleanup (#1885) | Jeff Widman | 2019-08-21 | 1 | -1/+8 |
| | | | | Remove unused import, whitespace, etc. No functional changes, just cleaning it up so the diffs of later changes are cleaner. | ||||
* | Update docs for api_version_auto_timeout_ms (#1812) | Jeff Widman | 2019-05-24 | 1 | -3/+7 |
| | | | | | | | | | The docs for `api_version_auto_timeout_ms` mention setting `api_version='auto'` but that value has been deprecated for years in favor of `api_version=None`. Updating the docs for now, and will remove support for `'auto'` in next major version bump. | ||||
* | 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 |