diff --git a/build b/build index 8fdd954..b393560 100644 --- a/build +++ b/build @@ -1 +1 @@ -22 \ No newline at end of file +23 \ No newline at end of file diff --git a/src/framework/KafkaManager.cpp b/src/framework/KafkaManager.cpp index 0d6aa7f..9605736 100644 --- 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 index ba41a30..75b9aa6 100644 --- 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);