diff options
| -rw-r--r-- | README.rst | 10 |
1 files changed, 5 insertions, 5 deletions
@@ -16,10 +16,10 @@ Python client for the Apache Kafka distributed stream processing system. kafka-python is designed to function much like the official java client, with a sprinkling of pythonic interfaces (e.g., consumer iterators). -kafka-python is best used with 0.9 brokers, but is backwards-compatible with +kafka-python is best used with newer brokers (0.10 or 0.9), but is backwards-compatible with older versions (to 0.8.0). Some features will only be enabled on newer brokers, however; for example, fully coordinated consumer groups -- i.e., dynamic partition -assignment to multiple consumers in the same group -- requires use of 0.9 kafka +assignment to multiple consumers in the same group -- requires use of 0.9+ kafka brokers. Supporting this feature for earlier broker releases would require writing and maintaining custom leadership election and membership / health check code (perhaps using zookeeper or consul). For older brokers, you can @@ -38,8 +38,8 @@ KafkaConsumer ************* KafkaConsumer is a high-level message consumer, intended to operate as similarly -as possible to the official 0.9 java client. Full support for coordinated -consumer groups requires use of kafka brokers that support the 0.9 Group APIs. +as possible to the official java client. Full support for coordinated +consumer groups requires use of kafka brokers that support the Group APIs: kafka v0.9+. See <http://kafka-python.readthedocs.org/en/master/apidoc/KafkaConsumer.html> for API and configuration details. @@ -119,7 +119,7 @@ for interacting with kafka brokers via the python repl. This is useful for testing, probing, and general experimentation. The protocol support is leveraged to enable a KafkaClient.check_version() method that probes a kafka broker and attempts to identify which version it is running -(0.8.0 to 0.9). +(0.8.0 to 0.10). Low-level |