python给kafka发送消息

适用于python3.7以下

import kafka

producer = kafka.KafkaProducer(bootstrap_servers='192.168.0.1:9092')
producer.send('test', b'Hello, Kafka!')
producer.close()