Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Remove SimpleClient, Producer, Consumer, Unittest (#1196) | Jeff Widman | 2019-10-11 | 1 | -133/+2 |
| | | | | | | | | | | | | | | | | | | 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`. | ||||
* | Error if connections_max_idle_ms not larger than request_timeout_ms (#1688) | Jeff Widman | 2019-03-14 | 1 | -2/+6 |
| | |||||
* | Migrate from `Unittest` to `pytest` (#1620) | Jeff Widman | 2018-11-10 | 1 | -7/+9 |
| | |||||
* | KAFKA-3888 Use background thread to process consumer heartbeats (#1266) | Dana Powers | 2017-12-21 | 1 | -2/+2 |
| | |||||
* | Return copy of consumer subscription set (#1029) | Dana Powers | 2017-03-13 | 1 | -0/+8 |
| | |||||
* | Fail-fast on timeout constraint violations during KafkaConsumer creation (#986) | Harel Ben-Attia | 2017-02-28 | 1 | -0/+8 |
| | |||||
* | Update imports from kafka.common -> kafka.errors / kafka.structs | Dana Powers | 2016-04-05 | 1 | -5/+5 |
| | |||||
* | Skip test that fails on windowswindows | Dana Powers | 2016-03-17 | 1 | -0/+2 |
| | |||||
* | bootstrap_servers no longer required in KafkaConsumer (localhost default) | Dana Powers | 2016-01-03 | 1 | -4/+0 |
| | |||||
* | Convert OffsetCommit and OffsetFetch protocol encode/decode | Dana Powers | 2015-12-10 | 1 | -2/+2 |
| | |||||
* | Fix test_consumer generator/list mock, reenable tests | Dana Powers | 2015-12-10 | 1 | -5/+2 |
| | |||||
* | Update to Payload namedtuples in consumer tests | Dana Powers | 2015-12-09 | 1 | -4/+4 |
| | |||||
* | Skip consumer tests that cause iterator errors -- needs investigation | Dana Powers | 2015-12-09 | 1 | -0/+3 |
| | |||||
* | (test) SimpleConsumer.reset_partition_offset should not raise exception on ↵ | Dana Powers | 2015-06-10 | 1 | -1/+16 |
| | | | | failure | ||||
* | (test) Consumer commit() should log errors and return True/False, not raise ↵ | Dana Powers | 2015-06-10 | 1 | -0/+24 |
| | | | | exceptions | ||||
* | Split consumer test class between Simple and MultiProcess | Dana Powers | 2015-06-10 | 1 | -1/+2 |
| | |||||
* | Add unit tests for SimpleConsumer error handling | Dana Powers | 2015-06-08 | 1 | -1/+74 |
| | |||||
* | Support optional partitions kwarg in MultiProcessConsumer | Dana Powers | 2015-05-17 | 1 | -2/+11 |
| | |||||
* | Move KafkaConsumer to kafka.consumer.kafka module; make available for import ↵ | Dana Powers | 2014-12-15 | 1 | -2/+1 |
| | | | | from kafka at top-level | ||||
* | Add a few basic KafkaConsumer tests | Dana Powers | 2014-12-15 | 1 | -0/+6 |
| | |||||
* | Merge pull request #227 from wizzat-feature/py3 | Dana Powers | 2014-09-07 | 1 | -2/+2 |
|\ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Python 3 Support Conflicts: kafka/producer.py test/test_client.py test/test_client_integration.py test/test_codec.py test/test_consumer.py test/test_consumer_integration.py test/test_failover_integration.py test/test_producer.py test/test_producer_integration.py test/test_protocol.py test/test_util.py | ||||
| * | Use base unittest or unittest2 depending on python version | Bruno Renié | 2014-09-03 | 1 | -2/+2 |
| | | |||||
* | | Cleanup tests: no more import *; remove unused | Dana Powers | 2014-09-04 | 1 | -14/+2 |
|/ | |||||
* | Various fixes | Mark Roberts | 2014-04-25 | 1 | -0/+22 |
Bump version number to 0.9.1 Update readme to show supported Kafka/Python versions Validate arguments in consumer.py, add initial consumer unit test Make service kill() child processes when startup fails Add tests for util.py, fix Python 2.6 specific bug. |