code: def __init__(self):
      threading.Thread.__init__(self)
      self.stop_event = threading.Event()
  
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 1 to create a new Producer object from inherited base classes: threading with example: obj = Producer()