https://telecominfraproject.atlassian.net/browse/WIFI-13450

Signed-off-by: stephb9959 <[email protected]>
Telecominfraproject · Mar 1, 2024 · 4e4b69e · 4e4b69e
1 parent 3d8f7c1
commit 4e4b69e
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/build b/build
@@ -1 +1 @@
-87
+88
diff --git a/src/framework/KafkaManager.cpp b/src/framework/KafkaManager.cpp
@@ -79,8 +79,8 @@ namespace OpenWifi {
 		Utils::SetThreadName("Kafka:Prod");
 		cppkafka::Configuration Config(
 			{{"client.id", MicroServiceConfigGetString("openwifi.kafka.client.id", "")},
-			 {"metadata.broker.list",MicroServiceConfigGetString("openwifi.kafka.brokerlist", "")},
-			 {"send.buffer.bytes", KafkaManager()->KafkaManagerMaximumPayloadSize() }
+			 {"metadata.broker.list",MicroServiceConfigGetString("openwifi.kafka.brokerlist", "")} // ,
+			 // {"send.buffer.bytes", KafkaManager()->KafkaManagerMaximumPayloadSize() }
 			}
  		);
 
@@ -277,7 +277,7 @@ namespace OpenWifi {
 	int KafkaManager::Start() {
 		if (!KafkaEnabled_)
 			return 0;
-		MaxPayloadSize_ = MicroServiceConfigGetInt("openwifi.kafka.max.payload", 2500000);
+		MaxPayloadSize_ = MicroServiceConfigGetInt("openwifi.kafka.max.payload", 250000);
 		ConsumerThr_.Start();
 		ProducerThr_.Start();
 		return 0;

diff --git a/src/framework/KafkaManager.h b/src/framework/KafkaManager.h
@@ -101,7 +101,7 @@ namespace OpenWifi {
 		std::string SystemInfoWrapper_;
 		KafkaProducer ProducerThr_;
 		KafkaConsumer ConsumerThr_;
-		std::uint64_t MaxPayloadSize_ = 2500000;
+		std::uint64_t MaxPayloadSize_ = 250000;
 
 		void PartitionAssignment(const cppkafka::TopicPartitionList &partitions);
 		void PartitionRevocation(const cppkafka::TopicPartitionList &partitions);