from kafka import KafkaProducer

# 创建生产者
producer = KafkaProducer(bootstrap_servers='10.10.14.250:9092')

# 发送消息
producer.send('test-topic', b'Hello, Kafka!')
producer.flush()

# 关闭生产者
producer.close()