网站介绍:文章浏览阅读2.9k次。01.启动zookeeper,启动Kafka,创建Kafka主题,kafka生产者,kafka消费者 详见之前文章:http://t.csdn.cn/JRFRs02.使用python语言,对Kafka进行数据的写入from kafka import KafkaProducerfrom kafka.errors import KafkaErrorproducer = KafkaProducer(bootstrap_servers='192.168.1.10:9092')while True:_producer = kafkaproducer( bootstrap_servers="192.168.119.28:39092".split(",
- 链接地址:https://blog.csdn.net/weixin_46408961/article/details/123891315
- 链接标题:python实现kafka生产以及sparkstream消费_producer = kafkaproducer( bootstrap_servers="192.1-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:2006
- 网站标签:producer = kafkaproducer( bootstrap_servers="192.168.119.28:39092".split("