changed bootstrap server conf for dev

kafka_utils/consumer.py

@@ -19,7 +19,7 @@ def get_consumer(topics):
         #            group_id=group_id,
         #            value_deserializer=lambda x: json.loads(x.decode('utf-8')))
         consumer = KafkaConsumer(
-            bootstrap_servers=[bootstrap_server],
+            bootstrap_servers=list(str(bootstrap_server).split(",")),
             value_deserializer=lambda x: json.loads(x.decode('utf-8')))
     
         consumer.subscribe(topics)    

kafka_utils/producer.py

@@ -10,7 +10,7 @@ bootstrap_server = os.environ.get(KAFKA_IP_HOST,default_value)
 
 def get_producer():
     try:
-        producer = KafkaProducer(bootstrap_servers=[bootstrap_server],
+        producer = KafkaProducer(bootstrap_servers=list(str(bootstrap_server).split(",")),
                                  value_serializer=lambda x: json.dumps(x).encode('utf-8'))
         logger.info('get_producer : producer returned successfully')
         return producer