funnel.json

{
    "generators": [
        {
            "topic": "funnelEvents",
            "vars": {
                "id": {
                    "_gen": "string",
                    "expr": "#{Name.username}"
                }
            },
            "key": {
                "_gen": "var",
                "var": "id"
            },
            "value": {
                "stage": {
                    "_gen": "stateMachine",
                    "for": {
                        "_gen": "var",
                        "var": "id"
                    },
                    "initial": "viewLandingPage",
                    "transitions": {
                        "viewLandingPage": "addItemToCart",
                        "addItemToCart": {
                            "_gen": "oneOf",
                            "choices": [
                                "viewCart", "addItemToCart"
                            ]
                        },
                        "viewCart": "checkout"
                    },
                    "states": {
                        "viewLandingPage": 1,
                        "addItemToCart": 2,
                        "viewCart": 3,
                        "checkout": 4
                    }
                }
            }
        }
    ],
    "connections": {
        "dev-kafka": {
            "kind": "kafka",
            "producerConfigs": {
                "bootstrap.servers": "localhost:9092",
                "key.serializer": "io.shadowtraffic.kafka.serdes.JsonSerializer",
                "value.serializer": "io.shadowtraffic.kafka.serdes.JsonSerializer"
            }
        }
    }
}