DMS for Kafka Event Source

DMS for Kafka is a message queuing service that provides Kafka premium instances.

If you use an Kafka trigger for a function, FunctionGraph periodically polls messages from a specific topic in Kafka and passes the messages as an input parameter to invoke the function.

For details, see Using a Kafka Trigger.

Kafka example event

dms4kafka_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

last updated: 2026-01-07 09:53:05 UTC - commit: b52ca97e4a0ec4c999820539460bd4ab093efa89