This is the documentation for v1.9 but the latest version is v1.13 . 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

Stop consumer after last messages

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'])
    ->withConsumerGroupId('group')
    ->stopAfterLastMessage()
    ->withHandler(new Handler)
    ->build();

$consumer->consume();