$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