DefaultBlockSourceObject
DefaultBlockSourceObject
Source cluster details e.g. source topic name , mapping name etc.
JSON Example
{
"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"
}
}string As ^.*$
topic
Required
Constraints: default:
Name of the source kafka topic
string As ^.*$
type
Required
Constraints: default:
Type of the collector json_metrics or json_events