remove uuid

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

Hide file tree

Showing 2 changed files with 1 addition and 11 deletions.
diff --git a/src/v2i-hub/CARMAStreetsPlugin/src/CARMAStreetsPlugin.cpp b/src/v2i-hub/CARMAStreetsPlugin/src/CARMAStreetsPlugin.cpp
@@ -84,13 +84,6 @@ void CARMAStreetsPlugin::InitKafkaConsumerProducers()
 	}
 
 	//Consumers
-	auto uuid = boost::uuids::random_generator()();
-	std::stringstream ss;
-	ss << uuid;
-	_subscribeToSpatConsumerGroupId += ss.str();
-	_subscribeToSchedulingPlanConsumerGroupId += ss.str();
-	_subscribeToSSMConsumerGroupId += ss.str();
-	//Todo further enhancement: Temporary fix for the consumer rebalancing due to multiple consumers join the same group upon restarting plugin.
 	_spat_kafka_consumer_ptr = client.create_consumer(kafkaConnectString, _subscribeToSpatTopic,_subscribeToSpatConsumerGroupId);
 	_scheduing_plan_kafka_consumer_ptr = client.create_consumer(kafkaConnectString, _subscribeToSchedulingPlanTopic,_subscribeToSchedulingPlanConsumerGroupId);
 	_ssm_kafka_consumer_ptr = client.create_consumer(kafkaConnectString, _subscribeToSsmTopic,_subscribeToSSMConsumerGroupId);

diff --git a/src/v2i-hub/CARMAStreetsPlugin/src/CARMAStreetsPlugin.h b/src/v2i-hub/CARMAStreetsPlugin/src/CARMAStreetsPlugin.h
@@ -16,10 +16,7 @@
 #include <mutex>
 #include "J2735MapToJsonConverter.h"
 #include "JsonToJ2735SpatConverter.h"
-#include "J2735ToSRMJsonConverter.h"
-#include <boost/uuid/uuid.hpp>
-#include <boost/uuid/uuid_generators.hpp>
-#include <boost/uuid/uuid_io.hpp>   
+#include "J2735ToSRMJsonConverter.h"   
 #include <kafka/kafka_client.h>
 #include <kafka/kafka_consumer_worker.h>
 #include "JsonToJ2735SSMConverter.h"