Skip to main content


The framework supports kafka as a datasource. It helps in interacting with kafka, to send/receive events on a kafka message bus.

8.5.1 Example spec

The datasources for kafka are defined in src/datasources. Here, two kafka clients kafka1.yaml and kafka2.yaml are defined in datasources.

├── config
└── src
├── datasources
│   └── httpbin.yaml
│   ├── kafka1.yaml
│   └── kafka2.yaml
├── events
├── functions
└── mappings

Sample configuration in kafka1.yaml

type: kafka
client_id: my_service
brokers: [ "kafka:9092" ]