把文本文档中的数据传送到kafka中

Question

通过Python爬取的数据存入到文本文档中，然后如何才能实现数据传送到kafka中

Answer 1

       

        msg = '采集到的数据'
        producer = KafkaProducer(bootstrap_servers='master:9092')

        # 指定主题和发送内容，将数据发送到kafka

        producer.send('test', msg.encode('utf-8'))