Kafka Job Example: JSON format
Kafka Message
{
"pitagname":"AXI.REM-1612-26B/PV.CV",
"pitagvalue":"84.488",
"pointtype":"Float32",
"questionable":0,
"substituted":0,
"timestamp":"2016-03-09T17:47:23.000",
"localtime":"2016-03-09T19:47:23.000",
"annotated":0,
"original_timestamp_from_sdk":"2016-03-09T19:47:23.000",
"path":"/Axibase/NUR/AXI/Harvest/CT-1612"
}
Kafka Message file.
Configuration
Field Name | Field Value |
---|---|
Message Format | JSON |
Use Listener | true |
Settings
Field Name | Field Value |
---|---|
Entity | path |
Time Field | localtime |
Time Format | yyyy-MM-dd'T'HH:mm:ss.SSS |
Excluded Fields | timestamp , pointtype , original_timestamp_from_sdk , questionable , annotated , substituted |
Metric Name Field | pitagname |
Metric Value Field | pitagvalue |
Kafka Job Configuration file. Import XML into Collector.
Command
series e:/axibase/nur/axi/harvest/ct-1612 d:2016-03-09T19:47:23.000Z m:AXI.REM-1612-26B/PV.CV=84.488