python - 如何运行用Python编写的kafka生产者？

Question

我是 Kafka 新手，但看过一些教程，所以我知道 Kafka 是如何工作的。我正在尝试运行我用Python编写的生产者，但在启动我的zookeeper服务器和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)

Answer 1

所以你的问题是如何运行Python脚本？只需保存它，使其可执行并执行:

chmod +x ./kProducer.py
python ./kproducer.py

更多详细信息请参见:How to Run a Python Script via a File or the Shell