mateusjunges/laravel-kafka
Laravel Kafka makes it easy to produce and consume Kafka messages in Laravel with a clean, expressive API and improved testability. Build producers and consumers quickly, integrate with your app workflows, and avoid painful Kafka testing setups.
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::consumer(['topic'])
->withConsumerGroupId('group')
->stopAfterLastMessage()
->withHandler(new Handler)
->build();
$consumer->consume();
<x-sponsors.request-sponsor/>
How can I help you explore Laravel packages today?