This is the documentation for
v1.12 but the latest version is
You can switch versions in the menu on the left/at the top.
Check your current version with the following command:
composer show mateusjunges/laravel-kafka
Stopping consumers after the last received message is useful if you want to consume all messages from a given
topic and stop your consumer when the last message arrives.
You can do it by adding a call to
stopAfterLastMessage method when creating your consumer:
This is particularly useful when using signal handlers.
$consumer = \Junges\Kafka\Facades\Kafka::createConsumer(['topic'])