如何用Python中的kafkaProducer发送数据？

Question

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

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

Answer 1

首先，安装“pykafka”=>；pip install pykafka

然后启动消费者（例如在终端中），运行以下命令：

from pykafka import KafkaClient
import threading

KAFKA_HOST = "localhost:9092" # Or the address you want

client = 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