How this package consumes messages about laravel-kafka

[mateusjunges]

Hey 👋 the documentation contains a class structure page, which explains how you can put everything together.

Where do I put this code? (In Laravel console command? a controller?)

Basically, a kafka consumer is a laravel console command.

How this package is listening the arriving messages. I mean, kafka will send an HTTPS request to all subscriber. How this laravel handles this request and send the request to this package, to be consumed?

Kafka will push the message to the broker, and the message will be pulled from the broker by a kafka consumer, which you will create and put in a laravel command.

Related to previous question: what is the purpose of the function of stop listening after last message? Which is the last message of pub/sub pattern?

You can use this when reading a topic from the begining (a topic that already has other messages). As soon as you reach the last message in that topic, the consumer should stop itself.

[giacomomasseron]

@mateusjunges thanks for your answer, I have a little bit of doubt left:

How this package is listening the arriving messages. I mean, kafka will send an HTTPS request to all subscriber. How this laravel handles this request and send the request to this package, to be consumed?

Kafka will push the message to the broker, and the message will be pulled from the broker by a kafka consumer, which you will create and put in a laravel command.

You need a laravel command always in listening, right?

Something like:

php artisan start-my-kafka-consumer

that never stops, always active.

[mateusjunges]

Yes, that's correct. I use supervisor to make sure that my consumer is always up and running.

[mateusjunges]

Closing this for now, feel free to @ mention me if you still have questions.