Kafkaopmon converts a JSON object into an kafka message, ready to be used as a time series
The library's constructor takes an URI argument. The URI's syntax is the database : Application name: kafka://<host>:<port>/<topic>
.
The library should be used calling the library's "publish" function with as argument a nlohmann::json
object. More details about the implementation are available in the "Technical information" chapter.
The library output is the return statement from the CPR message and, if successfull, the insertion of the JSON content to the TSDB.
the kafkaopmon URI presents as such: kafka://188.185.122.48:9092 Translating in the full, following URI eyample:
daq_application -c rest://localhost:12345 --name asd -i kafka://188.185.122.48:9092/opmon
- In a build environment clone the latest kafkaopmon tag from DUNE-DAQ
- Verify your environment includes the opmonlib module
- Compile your environment
- In a runtime environment, run the call URI
Consumers for this stream can be found in DUNEDAQ/microservices