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

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

  回复于 2024-04-20T20:37:25+08:00