Python3学习(二十二):Python KafkaProducer and KafkaConsumer的开发模块

在python中往kakfa写数据和读取数据,使用的是python-kafka库 消费者需持续写入数据,因groupid存在偏移量,才能看看到数据。 安装库的命令为pip install python-kafka -i https://pypi.douban.com/simple 其中返回的message为一个生成器,其中元素的type为<class 'kafka.consumer.fetcher
相关文章
相关标签/搜索