Build scalable microservices with NestLaravel.

# service + topic + event (with a consumer handler)
npx nestlaravel generate service orders
npx nestlaravel generate kafka-topic order-events --service orders --create
npx nestlaravel generate kafka-event order.created --service orders --consumer

use NestLaravel\Kafka\Contracts\EventBus;

DB::transaction(function () use ($order, $events) {
    $order->save();
    // written to the outbox in the same transaction
    $events->publish(new OrderCreated((string) $order->id, ['total' => $order->total]));
});

# run a consumer for a topic
php artisan kafka:consume orders.events "App\Modules\Payments\Infrastructure\Messaging\OrderCreatedHandler"

# the handler receives the standard event envelope
final class OrderCreatedHandler implements MessageHandler
{
    public function handle(array $event): void
    {
        $payload = $event['payload'];
    }
}

# clients only ever talk to the gateway
curl -H "Authorization: Bearer $TOKEN" \
     http://127.0.0.1:8000/api/v1/orders/health

# apps/orders-service/.env.example (excerpt)
INTERNAL_SERVICE_SECRET=
KAFKA_ENABLED=false
KAFKA_CLIENT_ID=orders-service
KAFKA_GROUP_ID=orders-service
KAFKA_TOPIC_DEFAULT=orders.events
KAFKA_SECURITY_PROTOCOL=plaintext