diff --git a/integration-msk-to-lambda/example.php b/integration-msk-to-lambda/example.php new file mode 100644 index 0000000..9e2834a --- /dev/null +++ b/integration-msk-to-lambda/example.php @@ -0,0 +1,54 @@ +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);