feat(config): Add Kafka configuration settings and environment-based service host resolution

Author: Bit-Maximum

app/adapters/kafka/lifespan.py

@@ -20,7 +20,7 @@ async def init_kafka(app: FastAPI) -> None:  # pragma: no cover
     :param app: current application.
     """
     app.state.kafka_producer = AIOKafkaProducer(
-        bootstrap_servers=settings.KAFKA_ADDR,
+        bootstrap_servers=settings.kafka_url, client_id=settings.KAFKA_CLIENT_ID, acks="all"
     )
     await app.state.kafka_producer.start()
 

app/core/config.py

@@ -71,7 +71,6 @@ class Settings(BaseSettings):
     ALLOWED_HOSTS: list[str] = ["localhost", "127.0.0.1", "api.localhost"]
     CORS_ORIGINS: list[str] = ["localhost", "127.0.0.1"]
 
-    APP_LOG_FILE_PATH: str = "logs/app.log"
     API_BASE_PATH: str = "/api"
     APP_VERSION: str = "latest"
     APP_HOST: str = "0.0.0.0"
@@ -177,7 +176,9 @@ def bearer_token_url(self) -> str:
     # E.G. http://localhost:4317
     OPENTELEMETRY_ENDPOINT: str | None = None
 
-    KAFKA_ADDR: list[str] = ["app-kafka:9092"]
+    # Kafka
+    KAFKA_CLIENT_ID: str = "api"
+    KAFKA_PORT: int = 9092
 
     # Additional Project Settings
     BASE_API_PATH: str = "/api"
@@ -215,7 +216,7 @@ def redis_url(self) -> URL:
             path = f"/{self.REDIS_DATABASE}"
         return URL.build(
             scheme="redis",
-            host=self.REDIS_HOST,
+            host="localhost" if self.ENVIRONMENT in ["debug", "local"] else self.REDIS_HOST,
             port=self.REDIS_PORT,
             password=self.REDIS_PASS,
             path=path,
@@ -230,12 +231,18 @@ def rabbit_url(self) -> URL:
         """
         return URL.build(
             scheme="amqp",
-            host=self.RABBITMQ_HOST,
+            host="localhost" if self.ENVIRONMENT in ["debug", "local"] else self.RABBITMQ_HOST,
             port=self.RABBITMQ_PORT,
             user=self.RABBITMQ_USER,
             password=self.RABBITMQ_PASS,
             path=self.RABBITMQ_VHOST,
         )
 
+    @property
+    def kafka_url(self) -> str:
+        """Assemble Kafka broker URL from settings."""
+        host = "localhost" if self.ENVIRONMENT in ["debug", "local"] else self.KAFKA_CONTAINER_HOST
+        return f"{host}:{self.KAFKA_PORT}"
+
 
 settings = Settings()

app/core/logger.py

@@ -100,7 +100,7 @@ def configure_logging() -> None:  # pragma: no cover
     logging.basicConfig(handlers=[intercept_handler], level=logging.NOTSET)
 
     log_level = (
-        LogLevel.DEBUG if settings.ENVIRONMENT in ["local", "pytest"] else settings.LOG_LEVEL
+        LogLevel.DEBUG if settings.ENVIRONMENT in ["debug", "pytest"] else settings.LOG_LEVEL
     )
 
     for logger_name in logging.root.manager.loggerDict: