Как выполнить мой слившийся производитель Python kafka и потребительский код с локальной машины Windows - PullRequest
0 голосов
/ 21 июня 2019
from confluent_kafka
import Producer

p = Producer({'bootstrap.servers': 'localhost:9092'})# localhost has IP 
    address of the linux system


p.produce('topic', "Hello World!")
p.flush()

Я запустил приведенный выше код в моих окнах простоя Python и запустил zookeeper и kafka в Unix-системе моей компании, используя putty.Моя программа работала вечно, и я убил казнь.

Может кто-нибудь помочь мне с этим?

...