@@ -22,7 +22,7 @@ int main(int argc, char* argv[])
2222 boost::program_options::options_description desc (" Program options" );
2323 desc.add_options ()
2424 (" kafka-host" , boost::program_options::value<std::string>()->required (), " Kafka broker hostname" )
25- (" influxdb-host " , boost::program_options::value<std::string>()->required (), " InfluxDB hostname" )
25+ (" influxdb-url " , boost::program_options::value<std::string>()->required (), " InfluxDB hostname" )
2626 (" influxdb-token" , boost::program_options::value<std::string>()->required (), " InfluxDB token" )
2727 (" influxdb-org" , boost::program_options::value<std::string>()->default_value (" cern" ), " InfluxDB organisation" )
2828 (" influxdb-bucket" , boost::program_options::value<std::string>()->default_value (" aliecs" ), " InfluxDB bucket" );
@@ -33,7 +33,7 @@ int main(int argc, char* argv[])
3333 std::vector<std::string> topics = {" aliecs.env_leave_state.RUNNING" };
3434 auto kafkaConsumer = std::make_unique<transports::KafkaConsumer>(vm[" kafka-host" ].as <std::string>() + " :9092" , topics, " aliecs-run-times" );
3535 auto httpTransport = std::make_unique<transports::HTTP>(
36- " http:// " + vm[" influxdb-host " ].as <std::string>() + " :8086 /api/v2/write?" +
36+ vm[" influxdb-url " ].as <std::string>() + " /api/v2/write?" +
3737 " org=" + vm[" influxdb-org" ].as <std::string>() + " &" +
3838 " bucket=" + vm[" influxdb-bucket" ].as <std::string>()
3939 );
0 commit comments