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

kafkaopensource_event.json

{
  "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.js

const { KafkaOpenSourceEvent } = require("@opentelekomcloud-community/fg-kafkaopensource-event");

exports.initializer = function (context, callback) {
  const logger = context.getLogger();
  logger.info("Function initialized");
  callback(null, "");
};

exports.handler = async function (event, context) {
  const logger = context.getLogger();

  logger.info("Function Name:", context.getFunctionName());

  const kafkaEvent = new KafkaOpenSourceEvent(event);

  logger.info("Trigger type:", kafkaEvent.getTriggerType());
  
  const output = {  
    trigger_type: kafkaEvent.getTriggerType(),
  };

  return output;
};

last updated: 2026-05-07 12:49:22 UTC - commit: b33b3f65aa4809f3bbb42c38e0f31e3067f81d22