From 2c742541f34cd43d43f969346267d04454b29223 Mon Sep 17 00:00:00 2001
From: jonny <32085184+jonnyjohnson1@users.noreply.github.com>
Date: Mon, 4 Nov 2024 17:07:33 -0600
Subject: [PATCH] + aiokafka import

---
 pyproject.toml           | 3 ++-
 topos/chat_api/server.py | 1 -
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/pyproject.toml b/pyproject.toml
index 595d38b..afdd663 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -39,13 +39,14 @@ python-multipart = "^0.0.9"
 pytest-asyncio = "^0.23.7"
 textblob = "^0.18.0.post0"
 pystray = "0.19.5"
-
+aiokafka = "^0.11.0"
 supabase = "^2.6.0"
 psycopg2-binary = "^2.9.9"
 en-core-web-sm = {url = "https://github.com/explosion/spacy-models/releases/download/en_core_web_sm-3.8.0/en_core_web_sm-3.8.0-py3-none-any.whl"}
 # en-core-web-lg = {url = "https://github.com/explosion/spacy-models/releases/download/en_core_web_lg-3.8.0/en_core_web_lg-3.8.0-py3-none-any.whl"}
 # en-core-web-md = {url = "https://github.com/explosion/spacy-models/releases/download/en_core_web_md-3.8.0/en_core_web_md-3.8.0-py3-none-any.whl"}
 # en-core-web-trf = {url = "https://github.com/explosion/spacy-models/releases/download/en_core_web_trf-3.8.0/en_core_web_trf-3.8.0-py3-none-any.whl"}
+
 [tool.poetry.group.dev.dependencies]
 pytest = "^7.4.3"
 pytest-asyncio = "^0.23.2"
diff --git a/topos/chat_api/server.py b/topos/chat_api/server.py
index e6bf1a2..ca06a3d 100644
--- a/topos/chat_api/server.py
+++ b/topos/chat_api/server.py
@@ -20,7 +20,6 @@ class MissedMessagesRequest(BaseModel):
 KAFKA_BOOTSTRAP_SERVERS = 'localhost:9092'
 KAFKA_TOPIC = 'chat_topic'
 
-
 # WebSocket connection manager
 class ConnectionManager:
     def __init__(self):