Kafka (Open-Source) Event Source¶

For the use of Open-Source Kafka triggers, please refer to Using an Open-Source Kafka Trigger.

Kafka example event¶

{
  "event_version": "v1.0",
  "event_time": 1576737962,
  "trigger_type": "KAFKA",
  "region": "eu-de",
  "instance_id": "08fd3e1b-cf56-401f-b4c6-81fd2a1d3ae6",
  "records": [
      {
          "messages": [
              "kafka message1",
              "kafka message2",
              "kafka message3",
              "kafka message4",
              "kafka message5"
          ],
          "topic_id": "topic-test"
      }
  ]
}

Parameter description¶

Parameter	Type	Description
event_version	String	Event version
event_time	String	Time when an event occurs
trigger_type	String	Event type: KAFKA
region	String	Region where a Kafka instance resides
instance_id	String	Kafka instance ID
messages	String[]	Message content
topic_id	String	Message ID

Example¶

index.php¶

<?php

require_once __DIR__ . '/../vendor/autoload.php';

use OTC\fg_kafkaopensource_event\KafkaOpenSourceEvent;

function initializer($context)
{
  $logger = $context->getLogger();
  $output = 'Initializer called for function: ' . $context->getFunctionName();
  $logger->debug($output);
  return $output;
}

function handler($event, $context)
{
  $logger = $context->getLogger();

  $logger->info('Function Name: ' . $context->getFunctionName());

  $kafkaOpenSourceEvent = new KafkaOpenSourceEvent($event);

  $logger->info('Trigger type: ' . $kafkaOpenSourceEvent->getTriggerType());

  $output = [
    'trigger_type' => $kafkaOpenSourceEvent->getTriggerType(),
  ];

  return $output;
}

Full sample code is available in the samples-doc/scratch-event-kafkaopensource.

last updated: 2026-09-22 12:15:14 UTC - commit: d206a39d29fa768880e8772002f6efdaa7bba431