CollectorRequestObject

Collector request object for is map of collect , blockid, kafka

JSON Example

{
    "source": {
        "topic": "metrics1",
        "type": "json_metrics",
        "mapping_name": "KMD RegEx",
        "properties": {
            "bootstrap.servers": "localhost:9092",
            "username": "string",
            "password": "string",
            "application.id": "omega-kafka-collector",
            "auto.offset.reset": "earliest",
            "group.id": "omega-consumer-group",
            "key.deserializer": "org.apache.kafka.common.serialization.StringDeserializer",
            "value.deserializer": "org.apache.kafka.common.serialization.StringDeserializer"
        }
    },
    "sink": {
        "topic": "vsa_metrics_raw"
    }
}

ConfigureBlockSourceObject

source

Required

Source cluster details e.g. source topic name , mapping name etc.

ConfigureBlockSinkObject

sink

Required

Target kafka cluster topic name

Parameter To

Create Collector