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.Моя программа работала вечно, и я убил казнь.
Может кто-нибудь помочь мне с этим?