code: def run(self):
      producer = KafkaProducer(bootstrap_servers="localhost:9092")
  
      while not self.stop_event.is_set():
          producer.send("my-topic", b"test")
          producer.send("my-topic", b"\xc2Hola, mundo!")
          time.sleep(1)
  
      producer.close()
  
file_path: kafka-python/example.py
imports: import threading, time
  from kafka import KafkaAdminClient, KafkaConsumer, KafkaProducer
  from kafka.admin import NewTopic
label_desc: Use image node_id 3 for calling the Producer obj's underlying member method code with example usage: obj.run() without return types