Skip to content

Commit

Permalink
Update CanConsumeMessages.php
Browse files Browse the repository at this point in the history
fix: added \Junges\Kafka\Exceptions\KafkaConsumerException throwable to consume()
  • Loading branch information
slushpuppy authored Sep 16, 2023
1 parent 9ee74c2 commit eb4c2d8
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/Contracts/CanConsumeMessages.php
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down

0 comments on commit eb4c2d8

Please sign in to comment.