feat: processing kafka events in PHP lambda

integration-msk-to-lambda/example.php

@@ -0,0 +1,54 @@
+<?php
+// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+// using bref/bref and bref/logger for simplicity
+
+use Bref\Context\Context;
+use Bref\Event\Kafka\KafkaEvent;
+use Bref\Event\Handler as StdHandler;
+use Bref\Logger\StderrLogger;
+
+require __DIR__ . '/vendor/autoload.php';
+
+class Handler implements StdHandler
+{
+    private StderrLogger $logger;
+    public function __construct(StderrLogger $logger)
+    {
+        $this->logger = $logger;
+    }
+
+    /**
+     * @throws JsonException
+     * @throws \Bref\Event\InvalidLambdaEvent
+     */
+    public function handle(mixed $event, Context $context): void
+    {
+        $kafkaEvent = new KafkaEvent($event);
+        $this->logger->info("Processing records");
+        $records = $kafkaEvent->getRecords();
+
+        foreach ($records as $record) {
+            try {
+                $key = $record->getKey();
+                $this->logger->info("Key: $key");
+
+                $values = $record->getValue();
+                $this->logger->info(json_encode($values));
+
+                foreach ($values as $value) {
+                    $this->logger->info("Value: $value");
+                }
+
+            } catch (Exception $e) {
+                $this->logger->error($e->getMessage());
+            }
+        }
+        $totalRecords = count($records);
+        $this->logger->info("Successfully processed $totalRecords records");
+    }
+}
+
+$logger = new StderrLogger();
+return new Handler($logger);