Remove admin client

Author: james0209

autoreduce_qp/queue_processor/confluent_consumer.py

@@ -27,16 +27,6 @@ def __init__(self, consumer=None):
         self.logger = logging.getLogger(__package__)
         self.logger.debug("Initializing the consumer")
 
-        kafka_broker = {'bootstrap.servers': KAFKA_BROKER_URL}
-        admin_client = AdminClient(kafka_broker)
-        topics = admin_client.list_topics().topics
-
-        if not topics:
-            # Create the topic
-            self.logger.info("Creating the topic '%s'", TRANSACTIONS_TOPIC)
-            new_topic = NewTopic(TRANSACTIONS_TOPIC, num_partitions=1, replication_factor=1)
-            admin_client.create_topics([new_topic])
-
         self.consumer = consumer
         self.message_handler = HandleMessage()
         self._stop_event = threading.Event()