CollectorDefaultBlockConfig

CollectorDefaultBlockConfig
CollectorDefaultBlockConfig

Get default collector block configuration

JSON Example 
{
    "source": {
        "topic": "metrics1",
        "type": "json_metrics",
        "mapping": {},
        "properties": {
            "bootstrap.servers": "localhost:9092",
            "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"
    }
}
DefaultBlockSourceObject
source
Required

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

DefaultBlockSinkObject
sink
Required

Target kafka cluster topic name

Returned By