如何在 Python 中使用 kafkaProducer 发送数据？

Question

我无法将数据发送到应该具有适当权限的远程 Kafka 集群。

该主题已在集群上创建。我也尝试以字节为单位发送数据，但仍然出现相同的错误。如果您有任何信息，它可能会很有帮助！我的错误在提供的图片上。

Answer 1

首先，安装“pykafka”=> pip install pykafka然后启动一个消费者（例如在终端中），运行以下命令：from pykafka import KafkaClientimport threadingKAFKA_HOST = "localhost:9092" # Or the address you wantclient = KafkaClient(hosts = KAFKA_HOST)topic = client.topics["test"]with topic.get_sync_producer() as producer:    for i in range(10):        message = "Test message " + str(i)        encoded_message = message.encode("utf-8")        producer.produce(encoded_message)您将能够看到：测试消息 0测试消息 1测试消息2...测试消息 9