From af619910184fe18a97a0a5e695d4f36ab60491e0 Mon Sep 17 00:00:00 2001
From: FlickerBean <FlickerBean@users.noreply.github.com>
Date: Tue, 8 Nov 2022 11:38:12 +0000
Subject: [PATCH] Update KafkaPubSubAdapter.php

---
 src/KafkaPubSubAdapter.php | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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);