项目目的

[kilakila-heart]

作者您好，没太搞懂，你的目的我的理解的，你用scrapy爬取数据作为生产者将数据存入kafka，消费者获取kafka的数据用于打印，kafka将获取的数据进行一个计时，当计数到了100，则关闭生产者对应的broker?
但好像消费者topic是“scrapy_kafka”，而生产者是“newtest”？？没太理解

[sunhailin-Leo]

@kilakila-heart Consumer的topic可以改哇~我那里的都是为了测试而已。最终topic是什么名字还是以你的项目开发为准。