python使用kafka方法

 时间:2024-10-12 10:48:36

1、切换到python3的环境下

python使用kafka方法

2、pip3 install kafka-python

python使用kafka方法

3、创建生产者p.pyfrom kafka import KafkaProducerproducer = KafkaProducer(bootstrap_servers=['kafka-server:9092'])for i in range(1,1001): str1 = '{0}'.format(i) future = producer.send('my_topic' , key= b'my_key', value= str.encode(str1), partition= 0) result = future.get(timeout= 10) print(result)

python使用kafka方法

4、vim c.pyfrom kafka import KafkaConsumerconsumer = KafkaConsumer(刻八圄俏9;my_topic', group_id= 'group2', bootstrap_servers= ['kafka-server:9092'])for msg in consumer: print(msg)

python使用kafka方法

5、执行生产者python p.py

python使用kafka方法

6、消费者进行消费python p.py

python使用kafka方法

7、在kafka服务器上查看topic my_topic中的内容,就是1到1000./kafka-console-consumer.sh --topic my_topic --from-beginning --bootstrap-server kafka-server:9092|more

python使用kafka方法
  • python类中修改属性值的3种方法
  • 西门子软件重启
  • deepin20如何卸载自带的文档查看器
  • LabVIEW生成XML文件
  • JS如何截取两个字符之间的字符
  • 热门搜索
    预防流感手抄报 我爱阅读手抄报资料 禁毒手抄报的内容 传统文化手抄报大全 长城手抄报图片大全 廉洁教育手抄报内容 科技创造未来手抄报 正月十五元宵节手抄报 防震手抄报内容 有关母亲节的手抄报