| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Remove SimpleClient, Producer, Consumer, Unittest (#1196) | Jeff Widman | 2019-10-11 | 1 | -25/+3 |
| | | | | | | | | | | | | | | | | | | | 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`. | ||||
| * | Rename KafkaAdmin to KafkaAdminClient | Jeff Widman | 2018-11-20 | 1 | -2/+2 |
| | | |||||
| * | Add KafkaAdmin class | Richard Lee | 2018-10-24 | 1 | -0/+2 |
| | | | | | | | Requires cluster version > 0.10.0.0, and uses new wire protocol classes to do many things via broker connection that previously needed to be done directly in zookeeper. | ||||
| * | Expose ConsumerRebalanceListener in all | Ben Harack | 2018-09-27 | 1 | -1/+1 |
| | | | | | | | This solves a warning in linters like PyCharm, which warns that a line like: from kafka import ConsumerRebalanceListener is actually accessing a protected member of a class or module. Adding it to __all__ should solve this. | ||||
| * | Don't use `kafka.common` internally1.3.5 | Jeff Widman | 2018-06-05 | 1 | -1/+1 |
| | | | | | This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`. | ||||
| * | use absolute imports everywhere (#1362) | Kevin Tindall | 2018-02-06 | 1 | -1/+1 |
| | | |||||
| * | Add kafka.serializer interfaces (#912) | Dana Powers | 2016-12-19 | 1 | -0/+1 |
| | | |||||
| * | from kafka import ConsumerRebalanceListener, OffsetAndMetadata | Dana Powers | 2016-09-04 | 1 | -1/+2 |
| | | |||||
| * | Always absolute_importabsolute_import | Dana Powers | 2016-08-02 | 1 | -0/+2 |
| | | |||||
| * | Update imports from kafka.common -> kafka.errors / kafka.structs | Dana Powers | 2016-04-05 | 1 | -1/+1 |
| | | |||||
| * | TopicPartition should be importable from top-level module | Dana Powers | 2016-02-15 | 1 | -0/+1 |
| | | |||||
| * | Add logging NullHandler to avoid No Handlers warningsnull_logger | Dana Powers | 2016-01-27 | 1 | -0/+12 |
| | | |||||
| * | Add KafkaProducer to kafka and kafka.producer module imports | Dana Powers | 2016-01-24 | 1 | -1/+2 |
| | | |||||
| * | Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, ↵deprecation_warnings | Dana Powers | 2016-01-12 | 1 | -4/+18 |
| | | | | | and KafkaConnection | ||||
| * | Reorg kafka imports | Dana Powers | 2016-01-07 | 1 | -11/+12 |
| | | | | | | | | - kafka.KafkaClient is new async client - kafka.SimpleClient is old sync client - update copyright / author info - add BrokerConnection; drop KafkaConnection | ||||
| * | Add Murmur2Partitioner to kafka __all__ imports - fix issue 471 | Dana Powers | 2015-12-02 | 1 | -1/+1 |
| | | |||||
| * | Set __version__ string in kafka/version.py | Dana Powers | 2015-06-04 | 1 | -3/+1 |
| | | |||||
| * | 2014 -> 2015 | David Arthur | 2015-02-03 | 1 | -1/+1 |
| | | |||||
| * | KafkaConsumer should be in __all__. | Kasper Jacobsen | 2015-01-09 | 1 | -1/+1 |
| | | |||||
| * | Move KafkaConsumer to kafka.consumer.kafka module; make available for import ↵ | Dana Powers | 2014-12-15 | 1 | -1/+1 |
| | | | | | from kafka at top-level | ||||
| * | Add TravisCI config for auto deployment | David Arthur | 2014-08-22 | 1 | -1/+1 |
| | | | | | Tags applied to master will now be automatically deployed on PyPI | ||||
| * | Set module version in separate VERSION file | Dana Powers | 2014-08-10 | 1 | -1/+3 |
| | | |||||
| * | Fix version in __init__.py to match setup.py | David Arthur | 2014-02-25 | 1 | -1/+1 |
| | | |||||
| * | Merge branch 'issue-35' | David Arthur | 2013-07-26 | 1 | -2/+3 |
| |\ | | | | | | | | | | | | | Conflicts: kafka/__init__.py kafka/consumer.py test/test_integration.py | ||||
| | * | Added the modules in __init__.py | Mahendra M | 2013-06-25 | 1 | -2/+3 |
| | | | |||||
| * | | Add exports in __init__ | Mahendra M | 2013-06-24 | 1 | -2/+4 |
| |/ | |||||
| * | PEP8-ify most of the files | Mahendra M | 2013-05-29 | 1 | -1/+1 |
| | | | | | consumer.py and conn.py will be done later after pending merges | ||||
| * | Big code re-org | David Arthur | 2013-04-02 | 1 | -5/+12 |
| | | |||||
| * | Integration tests passing | David Arthur | 2013-04-02 | 1 | -2/+1 |
| | | |||||
| * | Add Snappy support0.1-alpha | David Arthur | 2012-11-16 | 1 | -0/+1 |
| | | | | | Fixes #2 | ||||
| * | Packaging improvments | David Arthur | 2012-10-02 | 1 | -1/+11 |
| | | | | | | | | | | | | | | | | | | | | | | | | Can now: ```python import kafka kafka.KafkaClient("localhost", 9092) ``` or ```python from kafka.client import KafkaClient KafkaClient("localhost", 9092) ``` or ```python import kafka.client kafka.client.KafkaClient("localhost", 9092) ``` | ||||
| * | Moved codec stuff into it's own module | David Arthur | 2012-10-02 | 1 | -1/+1 |
| | | | | | Snappy will go there when I get around to it | ||||
| * | Start work on packaging issue #3 | David Arthur | 2012-10-02 | 1 | -0/+1 |
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |