32 lines
602 B
YAML
32 lines
602 B
YAML
$schema: ./schema.json
|
|
|
|
kafka:
|
|
kafka1:
|
|
brokers:
|
|
- 127.0.0.1:9092
|
|
client_id: "kaboom"
|
|
version: "0.10.2.0"
|
|
timeout: 10s
|
|
|
|
rules:
|
|
test1:
|
|
in:
|
|
- kafka: kafka1
|
|
topic: [ "topic1" ]
|
|
group_name: "kaboom"
|
|
transformation: |
|
|
{
|
|
"result": in.first + " " + in.second
|
|
}
|
|
- kafka: kafka1
|
|
topic: [ "topic2" ]
|
|
group_name: "kaboom"
|
|
transformation: |
|
|
{
|
|
"result": in.a + " " + in.b
|
|
}
|
|
out:
|
|
- kafka: kafka1
|
|
topic: ["result"]
|
|
timeout: 10s
|