update

app.py

@@ -6,39 +6,9 @@ import numpy as np
 import pandas as pd
 from fastapi import FastAPI
 from gamma.utils import association
-from kafka import KafkaProducer
 from pydantic import BaseModel
 from pyproj import Proj
 
-# Kafak producer
-use_kafka = False
-
-try:
-    print("Connecting to k8s kafka")
-    BROKER_URL = "quakeflow-kafka-headless:9092"
-    # BROKER_URL = "34.83.137.139:9094"
-    producer = KafkaProducer(
-        bootstrap_servers=[BROKER_URL],
-        key_serializer=lambda x: dumps(x).encode("utf-8"),
-        value_serializer=lambda x: dumps(x).encode("utf-8"),
-    )
-    use_kafka = True
-    print("k8s kafka connection success!")
-except BaseException:
-    print("k8s Kafka connection error")
-    try:
-        print("Connecting to local kafka")
-        producer = KafkaProducer(
-            bootstrap_servers=["localhost:9092"],
-            key_serializer=lambda x: dumps(x).encode("utf-8"),
-            value_serializer=lambda x: dumps(x).encode("utf-8"),
-        )
-        use_kafka = True
-        print("local kafka connection success!")
-    except BaseException:
-        print("local Kafka connection error")
-print(f"Kafka status: {use_kafka}")
-
 app = FastAPI()
 
 PROJECT_ROOT = os.path.realpath(os.path.join(os.path.dirname(__file__), ".."))