用Python进行kafka操作

阅读量：

首要步骤是完成 PyKafka 的安装过程：

复制代码

    $ pip install pykafka

建立与kafka的连接，其默认使用的端口号为9092

复制代码

 >>> from pykafka import KafkaClient

    
 >>> client = KafkaClient(hosts="127.0.0.1:9092")

查阅相关主题：

复制代码

    client.topics

选定一个特定主题以生成对应的消息内容：

复制代码

 >>> topic = client.topics['my.test']

    
 >>> producer = topic.get_producer()
    
 >>> producer.produce(['test message ' + i ** 2 for i in range(4)])

消费信息：

复制代码

 >>> consumer = topic.get_si

全部评论 (0)

还没有任何评论哟~

是否确定退出登录?

用Python进行kafka操作

全部评论 (0)

相关文章推荐