.CDK2.2.0(0.10.2) 4.Python 2.7.15 2 环境准备 在使用Python访问Kafka前,还需要为Python环境安装相关的Kafka包,这里Fayson使用官网推荐使用的confluent-kafka-python 该依赖包的GitHub地址为:https://github.com/confluentinc/confluent-kafka-python,关于confluent-kafka-python的详细说明可以参考 2.如果使用confluent-kafka-python访问Kerberos环境下的Kafka,需要安装librdkafka及其依赖包,然后使用PyPi命令通过源码的方式安装。
实践环境 Python 3.6.2 confluent-kafka 2.2.0 confluent-kafka简介 Confluent在GitHub上开发和维护的confluent-kafka-python kafka-clients/python/current/overview.html#initialization https://docs.confluent.io/platform/current/clients/confluent-kafka-python
Kafka客户端:介绍如何使用confluent-kafka-python或kafka-python库连接Kafka服务器,生产消息、消费消息、管理主题等操作。
performance Python client based on Librdkafka with full protocol support. https://github.com/confluentinc/confluent-kafka-python
Docker镜像 Confluent kafka 的docker镜像 客户端工具 Apache Kafka的Python客户端:kafka-python Confluent kafka的Python客户端: confluent-kafka-python
如,Python客户端: confluent-kafka-python 。Python客户端还有纯python实现的:kafka-python。 下面是Python例子(以confluent-kafka-python为例): Producer: from confluent_kafka import Producer p = Producer