Как отправить данные с kafkaProducer в Python?

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