From 19060e3768c31b731808efc0a65e844a114bb35d Mon Sep 17 00:00:00 2001 From: Simon Podlipsky Date: Wed, 29 Oct 2025 09:36:59 +0100 Subject: [PATCH 1/2] fix: callback types --- src/Clients/Consumer/KafkaConsumer.php | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/src/Clients/Consumer/KafkaConsumer.php b/src/Clients/Consumer/KafkaConsumer.php index 74c4b34..1abe643 100644 --- a/src/Clients/Consumer/KafkaConsumer.php +++ b/src/Clients/Consumer/KafkaConsumer.php @@ -83,9 +83,9 @@ function (RdKafkaConsumer $kafka, int $err, array|null $partitions = null): void } /** - * @param callable(Message) : void $onSuccess - * @param callable() : void $onPartitionEof - * @param callable() : void $onTimedOut + * @param callable(Message):void $onSuccess + * @param (callable():void)|null $onPartitionEof + * @param (callable():void)|null $onTimedOut */ public function start( int $timeoutMs, @@ -97,8 +97,8 @@ public function start( } /** - * @param callable(Message) : void $processRecord - * @param callable(ConsumerRecords) : void $onBatchProcessed + * @param (callable(Message):void)|null $processRecord + * @param (callable(ConsumerRecords):void)|null $onBatchProcessed */ public function startBatch( int $maxBatchSize, @@ -151,8 +151,8 @@ public function shutdown(): void /** * @param callable(Message): void $onSuccess - * @param callable() : void $onPartitionEof - * @param callable() : void $onTimedOut + * @param (callable():void)|null $onPartitionEof + * @param (callable():void)|null $onTimedOut */ private function doStart( int $timeoutMs, From 64544871aef1158c9082ce2736ba87e9935d0f67 Mon Sep 17 00:00:00 2001 From: Simon Podlipsky Date: Wed, 29 Oct 2025 09:40:42 +0100 Subject: [PATCH 2/2] Update src/Clients/Consumer/KafkaConsumer.php Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> --- src/Clients/Consumer/KafkaConsumer.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/Clients/Consumer/KafkaConsumer.php b/src/Clients/Consumer/KafkaConsumer.php index 1abe643..9c0bc00 100644 --- a/src/Clients/Consumer/KafkaConsumer.php +++ b/src/Clients/Consumer/KafkaConsumer.php @@ -150,7 +150,7 @@ public function shutdown(): void } /** - * @param callable(Message): void $onSuccess + * @param callable(Message):void $onSuccess * @param (callable():void)|null $onPartitionEof * @param (callable():void)|null $onTimedOut */