[{"label":"Latest (2.0.1)","version":"latest"}]
telco-cloud-service-assurance
CollectorRequestObject
Collector request object for is map of collect , blockid, kafka
Properties
source
Required
Source cluster details e.g. source topic name , mapping name etc.
JSON Example
{
"sink": {
"topic": "vsa_metrics_raw"
},
"source": {
"mapping_name": "KMD RegEx",
"properties": {
"application.id": "omega-kafka-collector",
"auto.offset.reset": "earliest",
"bootstrap.servers": "localhost:9092",
"group.id": "omega-consumer-group",
"key.deserializer": "org.apache.kafka.common.serialization.StringDeserializer",
"password": "string",
"username": "string",
"value.deserializer": "org.apache.kafka.common.serialization.StringDeserializer"
},
"topic": "metrics1",
"type": "json_metrics"
}
}
[{"label":"Latest (2.0.1)","version":"latest"}]
telco-cloud-service-assurance
Parameter To
Create Collector
