address comments

usdot-fhwa-OPS · Jul 6, 2023 · 0c1bddd · 0c1bddd
1 parent 70df5ec
commit 0c1bddd
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/tmx/TmxUtils/src/kafka/kafka_producer_worker.cpp b/src/tmx/TmxUtils/src/kafka/kafka_producer_worker.cpp
@@ -35,8 +35,7 @@ namespace tmx::utils
 
     kafka_producer_worker::kafka_producer_worker(const std::string &brokers)
         : _broker_str(brokers), _run(true)
-    {
-        init_producer();		
+    {	
     }
 
     bool kafka_producer_worker::init()

diff --git a/src/v2i-hub/CARMAStreetsPlugin/src/CARMAStreetsPlugin.cpp b/src/v2i-hub/CARMAStreetsPlugin/src/CARMAStreetsPlugin.cpp
@@ -78,6 +78,10 @@ void CARMAStreetsPlugin::InitKafkaConsumerProducers()
 
 	//Producer
 	_kafka_producer_ptr = client.create_producer(kafkaConnectString);
+	if(!_kafka_producer_ptr->init_producer())
+	{
+		return;
+	}
 
 	//Consumers
 	auto uuid = boost::uuids::random_generator()();