已解決430363個問題，去搜搜看，總會有你想問的

如何在 Python 中使用 kafkaProducer 發送數據？

關注

首頁猿問如何在 Python 中使用...

Python

慕碼人8056858 2021-09-11 20:48:09

我無法將數據發送到應該具有適當權限的遠程 Kafka 集群。該主題已在集群上創建。我也嘗試以字節為單位發送數據，但仍然出現相同的錯誤。如果您有任何信息，它可能會很有幫助！我的錯誤在提供的圖片上。

查看完整描述

1 回答

一只萌萌小番薯

TA貢獻1795條經驗獲得超7個贊

首先，安裝“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

反對回復 2021-09-11

關注

舉報

0/150

提交

取消