Kafka (OPENSOURCEKAFKA)¶

Sample event¶

kafka_event.json¶

{
  "event_version": "v1.0",
  "event_time": 1576737962,
  "trigger_type": "KAFKA",
  "region": "region",
  "instance_id": "81335d56-b9fe-4679-ba95-7030949cc76b",
  "records": [
      {
          "messages": [
              "kafka message1",
              "kafka message2",
              "kafka message3",
              "kafka message4",
              "kafka message5"
          ],
          "topic_id": "topic-test"
      }
  ]
}

Class definitions¶

For class definitions for Kafka trigger event, see: Classe definitions

Sample¶

For sample on how to use trigger, see: Sample

last updated: 2025-09-23 09:31:56 UTC - commit: 70dfd27683766d95e95edd34387e5c0f102dbc02