如何使用Python中的kafkaProducer发送数据?

loading...


0

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

该主题已在群集上创建 . 我也试图以字节发送数据,但仍然有相同的错误 . 如果您有任何信息,可能会有很大的帮助!我所遇到的错误就在提供的图片上 .

Kafka error

loading...

1回答

  • 0

    首先,安装“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

评论

暂时没有评论!