我是新来Kafka，但看到了一些教程，所以我知道Kafka如何工作。我试图运行一个生产者，我已经写在python，但我不知道如何运行这个文件后，我已经启动了我的zookeeper服务器和Kafka服务器。如果有人能告诉我要在命令提示符下编写的命令的结构，我将不胜感激。谢谢！
Kafka制作人：

import json
import time
from kafka import KafkaProducer
from kafka.errors import KafkaError
from kafka.future import log

if __name__ == "__main__":
  producer = KafkaProducer(bootstrap_servers= 'localhost: 9092')

future = producer.send('my-topic', b"test")

try:
    record_metadata = future.get( timeout=10)
except KafkaError :
    log.exeption()
    pass

print( record_metadata.topic)
print(record_metadata.partition)
print(record_metadata.offset)

producer = KafkaProducer(value_serializer = lambda m: json.dumps(m).encode('ascii'))
producer.send('json-topic',{'key':'value'})

for _ in range (100):
    producer.send('my-topic', b"test")
    producer.send('my-topic',b"\xc2Hola, mundo!")
    time.sleep(1)