diff --git a/src/Statistics/Logger/MemoryStatisticsLogger.php b/src/Statistics/Logger/MemoryStatisticsLogger.php
index f79d891..c75fa33 100644
--- a/src/Statistics/Logger/MemoryStatisticsLogger.php
+++ b/src/Statistics/Logger/MemoryStatisticsLogger.php
@@ -103,7 +103,7 @@ class MemoryStatisticsLogger implements StatisticsLogger
                 continue;
             }
 
-            $this->createRecord($statistic);
+            $this->createRecord($statistic, $appId);
 
             $currentConnectionCount = $this->channelManager->getConnectionCount($appId);
 
@@ -140,9 +140,10 @@ class MemoryStatisticsLogger implements StatisticsLogger
      * Create a new record using the Statistic Driver.
      *
      * @param  Statistic  $statistic
+     * @param  mixed  $appId
      * @return void
      */
-    public function createRecord(Statistic $statistic)
+    public function createRecord(Statistic $statistic, $appId)
     {
         $this->driver::create($statistic->toArray());
     }
diff --git a/src/Statistics/Logger/RedisStatisticsLogger.php b/src/Statistics/Logger/RedisStatisticsLogger.php
index 47d2cac..22ec483 100644
--- a/src/Statistics/Logger/RedisStatisticsLogger.php
+++ b/src/Statistics/Logger/RedisStatisticsLogger.php
@@ -122,7 +122,7 @@ class RedisStatisticsLogger implements StatisticsLogger
                     continue;
                 }
 
-                $this->createRecord($statistic);
+                $this->createRecord($statistic, $appId);
 
                 $currentConnectionCount = $this->channelManager->getConnectionCount($appId);
 
@@ -203,9 +203,10 @@ class RedisStatisticsLogger implements StatisticsLogger
      * Create a new record using the Statistic Driver.
      *
      * @param  array  $statistic
+     * @param  mixed  $appId
      * @return void
      */
-    protected function createRecord(array $statistic): void
+    protected function createRecord(array $statistic, $appId): void
     {
         $this->driver::create([
             'app_id' => $appId,