python实现kafka生产以及sparkstream消费_producer = kafkaproducer( bootstrap_servers="192.1-CSDN博客

网站介绍:文章浏览阅读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(",