diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index 9760be9..c08fe12 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -6,6 +6,7 @@
   <component name="ChangeListManager">
     <list default="true" id="e7096e79-455b-4aa3-858d-e2defd65b8a9" name="Changes" comment="revert: tracking migration">
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/bot/reddit/track.py" beforeDir="false" afterPath="$PROJECT_DIR$/bot/reddit/track.py" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
@@ -31,18 +32,18 @@
     <option name="hideEmptyMiddlePackages" value="true" />
     <option name="showLibraryContents" value="true" />
   </component>
-  <component name="PropertiesComponent"><![CDATA[{
-  "keyToString": {
-    "Python.loadtest.executor": "Run",
-    "Python.main.executor": "Run",
-    "Python.track (1).executor": "Run",
-    "Python.track.executor": "Run",
-    "RunOnceActivity.OpenProjectViewOnStart": "true",
-    "RunOnceActivity.ShowReadmeOnStart": "true",
-    "git-widget-placeholder": "master",
-    "settings.editor.selected.configurable": "preferences.lookFeel"
+  <component name="PropertiesComponent">{
+  &quot;keyToString&quot;: {
+    &quot;Python.loadtest.executor&quot;: &quot;Run&quot;,
+    &quot;Python.main.executor&quot;: &quot;Run&quot;,
+    &quot;Python.track (1).executor&quot;: &quot;Run&quot;,
+    &quot;Python.track.executor&quot;: &quot;Run&quot;,
+    &quot;RunOnceActivity.OpenProjectViewOnStart&quot;: &quot;true&quot;,
+    &quot;RunOnceActivity.ShowReadmeOnStart&quot;: &quot;true&quot;,
+    &quot;git-widget-placeholder&quot;: &quot;master&quot;,
+    &quot;settings.editor.selected.configurable&quot;: &quot;preferences.lookFeel&quot;
   }
-}]]></component>
+}</component>
   <component name="RecentsManager">
     <key name="MoveFile.RECENT_KEYS">
       <recent name="C:\Users\matth\PycharmProjects\clashkingtracking\bot\reddit" />
diff --git a/bot/reddit/track.py b/bot/reddit/track.py
index b279211..656390a 100644
--- a/bot/reddit/track.py
+++ b/bot/reddit/track.py
@@ -1,3 +1,5 @@
+import asyncio
+
 import asyncpraw
 import re
 import orjson
@@ -20,8 +22,10 @@
     user_agent="Reply Recruit"
 )
 
-async def main():
-    producer = KafkaProducer(bootstrap_servers=["85.10.200.219:9092"], api_version=(3, 6, 0))
+producer = KafkaProducer(bootstrap_servers=["85.10.200.219:9092"], api_version=(3, 6, 0))
+
+
+async def post_stream():
     while True:
         try:
             count = 0
@@ -45,3 +49,32 @@ async def main():
         except Exception as e:
             continue
 
+async def comment_stream():
+    while True:
+        try:
+            count = 0
+            sub = await reddit.subreddit(subreddit)
+            async for comment in sub.stream.comments():
+                if count < 100:  # This removes the 100 historical submissions that SubredditStream pulls.
+                    count += 1
+                    continue
+                json_data = {"type": "redditcomment",
+                             "data" : {"author" : comment.author.name,
+                                       "avatar" : comment.author.icon_img,
+                                       "body" : comment.body,
+                                       "url" : comment.permalink,
+                                       "score" : comment.score,
+                                       "submission_author" : comment.submission.author.name,
+                                       "submission_title" : comment.submission.title
+                                       }}
+                producer.send(topic="reddit", value=orjson.dumps(json_data), timestamp_ms=int(pend.now(tz=pend.UTC).timestamp()) * 1000)
+        except Exception as e:
+            continue
+
+
+async def main():
+    loop = asyncio.get_event_loop()
+    loop.create_task(comment_stream())
+    loop.create_task(post_stream())
+
+