DMS (for Kafka)¶
Sample 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"
}
]
}
Class definitions¶
For class definitions for DMS trigger event, see: Classe definitions
Sample¶
For sample on how to use trigger, see: Sample