smyte fork of confluent的apache kafka python客户端
confluent-kafka-smyte的Python项目详细描述
smyte fork
==
我们创建了一个fork以使时间戳工作。一旦我们的
[拉取请求]（https://github.com/confluentinc/confluent kafka python/pull/50）被合并到主线
confluent的apache kafka客户端（用于python）中，就会删除该请求。提供
完整的kafka协议支持，具有出色的性能和可靠性。
python绑定为apache kafka 0.9的平衡用户组提供了支持
的高级生产者和消费者。
有关更多信息，请参阅[api文档]（http://docs.confluent.io/current/clients/confluent-kafka-python/index.html）信息。
**许可证**:[Apache许可证v2.0（http://www.Apache.org/licenses/licenses-2.0）
生产（“mytopic”data.encode（'utf-8'）
p.flush（）
```
**高级消费者：*
``python
默认.topic.config'：{auto.offset.reset'：'minimum'}）
c.subscribe（['mytopic']）
运行时running=True
运行时：
msg=c.poll（）
如果不是msg.error（）：
打印（'Received message:%s'%msg.value（）.decode（'utf-8'））
elif msg.error（）.code（）！AbKaReal.Myg.Error（）：BR/>运行= false
C.（）BR/>‘BR/> BR/>参见[实例]（示例）。更多的例子。BR/> BR/> Buffer-Audio: < BR/> Python客户端=（BR/>）Python客户端（以及底层C库LabordKaFKA）支持
所有Boosivices版本和Gt；＝0.8。=由于代理版本0.8和0.9中的kafka协议的性质，客户机假设代理实际支持的协议版本是不安全的，因此您需要提示python客户机它可能使用的协议版本是什么。这是通过两个配置设置来完成的：
*`broker.version.fallback=your戋broker戋version`（默认值为0.9.0.1）
*`api.version.request=true false`（默认值为false）
使用Kafka 0.10或更高版本的代理时，只需设置
`api.version.request=true`.
如果使用Kafka Broker 0.9或0.8，则应该将api.version.request=false`（默认）设置为api.version.request=false`（默认），并将broker.version.fallback`设置为broker.version.fallback`设置为broker版本，
例如broker.version.fallback=0.9.0.0.1`。
>更多信息请登录：
https://github.com/edindenhill/librdkafka/wiki/broker版本兼容性
<<<
======2.7或pytho3.x
==br/>
*[librdkafka]（https://github.com/edenhill/librdkafka）>；=0.9.1
**从pypi安装：*
$pip安装合流卡夫卡
=
非标准位置提供库目录包含：
$c_include_path=/path/to/include library_path=/path/to/lib python setup.py…
==
**运行单元测试：**
$py.test
**注意**：需要“py.test”，通过“pip install py test”安装
**运行集成测试：**
**警告**：这些测试需要一个活动的Kafka集群，并将使用名为“测试”的主题。
e docs
或：
$python setup.py build_sphinx
文档将在“docs/u build/”中生成。
==
我们创建了一个fork以使时间戳工作。一旦我们的
[拉取请求]（https://github.com/confluentinc/confluent kafka python/pull/50）被合并到主线
confluent的apache kafka客户端（用于python）中，就会删除该请求。提供
完整的kafka协议支持，具有出色的性能和可靠性。
python绑定为apache kafka 0.9的平衡用户组提供了支持
的高级生产者和消费者。
有关更多信息，请参阅[api文档]（http://docs.confluent.io/current/clients/confluent-kafka-python/index.html）信息。
**许可证**:[Apache许可证v2.0（http://www.Apache.org/licenses/licenses-2.0）
生产（“mytopic”data.encode（'utf-8'）
p.flush（）
```
**高级消费者：*
``python
默认.topic.config'：{auto.offset.reset'：'minimum'}）
c.subscribe（['mytopic']）
运行时running=True
运行时：
msg=c.poll（）
如果不是msg.error（）：
打印（'Received message:%s'%msg.value（）.decode（'utf-8'））
elif msg.error（）.code（）！AbKaReal.Myg.Error（）：BR/>运行= false
C.（）BR/>‘BR/> BR/>参见[实例]（示例）。更多的例子。BR/> BR/> Buffer-Audio: < BR/> Python客户端=（BR/>）Python客户端（以及底层C库LabordKaFKA）支持
所有Boosivices版本和Gt；＝0.8。=由于代理版本0.8和0.9中的kafka协议的性质，客户机假设代理实际支持的协议版本是不安全的，因此您需要提示python客户机它可能使用的协议版本是什么。这是通过两个配置设置来完成的：
*`broker.version.fallback=your戋broker戋version`（默认值为0.9.0.1）
*`api.version.request=true false`（默认值为false）
使用Kafka 0.10或更高版本的代理时，只需设置
`api.version.request=true`.
如果使用Kafka Broker 0.9或0.8，则应该将api.version.request=false`（默认）设置为api.version.request=false`（默认），并将broker.version.fallback`设置为broker.version.fallback`设置为broker版本，
例如broker.version.fallback=0.9.0.0.1`。
>更多信息请登录：
https://github.com/edindenhill/librdkafka/wiki/broker版本兼容性
<<<
======2.7或pytho3.x
==br/>
*[librdkafka]（https://github.com/edenhill/librdkafka）>；=0.9.1
**从pypi安装：*
$pip安装合流卡夫卡
=
非标准位置提供库目录包含：
$c_include_path=/path/to/include library_path=/path/to/lib python setup.py…
==
**运行单元测试：**
$py.test
**注意**：需要“py.test”，通过“pip install py test”安装
**运行集成测试：**
**警告**：这些测试需要一个活动的Kafka集群，并将使用名为“测试”的主题。
e docs
或：
$python setup.py build_sphinx
文档将在“docs/u build/”中生成。
欢迎加入QQ群-->： 979659372
