make kafka topic an env variable

app/main.py

@@ -19,7 +19,7 @@
 ## pfdcm
 app = FastAPI(
     title='consumer',
-    version='0.0.1',
+    version='0.1.0',
     contact={"name": "FNNDSC", "email": "[email protected]"},
     openapi_tags=[],
     description=description
@@ -32,6 +32,7 @@
     allow_headers=["*"],
 )
 loop = asyncio.get_event_loop()
+kafka_topic = os.getenv('KAFKA_TOPIC')
 
 async def consume():
     consumer = None
@@ -41,7 +42,7 @@ async def consume():
     except Exception as ex:
         print(f"{ex}. Retrying in 10 seconds")
         sleep(10)
-        consumer = AIOKafkaConsumer("test", bootstrap_servers=f"{os.getenv('KAFKA_URL')},{os.getenv('KAFKA_URL')}",
+        consumer = AIOKafkaConsumer(kafka_topic, bootstrap_servers=f"{os.getenv('KAFKA_URL')},{os.getenv('KAFKA_URL')}",
                                     loop=loop)
 
     await consumer.start()

docker-compose.yml

@@ -10,6 +10,7 @@ services:
     command: uvicorn app.main:app --reload --workers 1 --host 0.0.0.0 --port 2020
     environment:
       KAFKA_URL: "127.0.0.1:9092"
+      KAFKA_TOPIC: "test"
     volumes:
       - ./:/app/