| Commit message (Collapse) | Author | Age | Files | Lines |
|
|
|
|
| |
* Add kafka 0.10.2.1 into integration testing version
* Disable tests for python 2.6 and kafka 0.8.0 and 0.8.1.1
* Remove references to python 2.6 support
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
producer.flush
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
|
|
|
| |
* Add 0.10.0.1 fixture resources
* Use new release 0.10.0.1 for 0.10 testing
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
| |
`json.loads()` is for deserialising.
|
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
API up in toc
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
and KafkaConnection
|
| |
|
| |
|
| |
|