From eb4c2d8454a58d8eb8e7f76716b5436f34fdad66 Mon Sep 17 00:00:00 2001 From: slushpuppy Date: Sat, 16 Sep 2023 14:02:46 +0800 Subject: [PATCH] Update CanConsumeMessages.php fix: added \Junges\Kafka\Exceptions\KafkaConsumerException throwable to consume() --- src/Contracts/CanConsumeMessages.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/Contracts/CanConsumeMessages.php b/src/Contracts/CanConsumeMessages.php index 69f9288b..40595e44 100644 --- a/src/Contracts/CanConsumeMessages.php +++ b/src/Contracts/CanConsumeMessages.php @@ -9,7 +9,7 @@ interface CanConsumeMessages /** * Consume messages from a kafka topic in loop. * - * @throws \RdKafka\Exception|\Carbon\Exceptions\Exception + * @throws \RdKafka\Exception|\Carbon\Exceptions\Exception|\Junges\Kafka\Exceptions\KafkaConsumerException */ public function consume(): void;