diff --git a/src/KafkaPubSubAdapter.php b/src/KafkaPubSubAdapter.php
index 5d38e23..9b720a5 100644
--- a/src/KafkaPubSubAdapter.php
+++ b/src/KafkaPubSubAdapter.php
@@ -75,7 +75,7 @@ public function subscribe($channel, callable $handler)
                     if ($payload === 'unsubscribe') {
                         $isSubscriptionLoopActive = false;
                     } else {
-                        call_user_func($handler, $payload);
+                        call_user_func_array($handler, [$payload, $message]);
                     }
 
                     $this->consumer->commitAsync($message);