{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,3,13]],"date-time":"2026-03-13T01:21:09Z","timestamp":1773364869065,"version":"3.50.1"},"reference-count":42,"publisher":"Springer Science and Business Media LLC","issue":"3","license":[{"start":{"date-parts":[[2021,7,26]],"date-time":"2021-07-26T00:00:00Z","timestamp":1627257600000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/creativecommons.org\/licenses\/by\/4.0"},{"start":{"date-parts":[[2021,7,26]],"date-time":"2021-07-26T00:00:00Z","timestamp":1627257600000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/creativecommons.org\/licenses\/by\/4.0"}],"funder":[{"DOI":"10.13039\/100009117","name":"Technische Universit\u00e4t Chemnitz","doi-asserted-by":"crossref","id":[{"id":"10.13039\/100009117","id-type":"DOI","asserted-by":"crossref"}]}],"content-domain":{"domain":["link.springer.com"],"crossmark-restriction":false},"short-container-title":["J Supercomput"],"published-print":{"date-parts":[[2022,2]]},"abstract":"<jats:title>Abstract<\/jats:title><jats:p>The growth of the Internet of Things (IoTs) and the number of connected devices is driven by emerging applications and business models. One common aim is to provide systems able to synchronize these devices, handle the big amount of daily generated data and meet business demands. This paper proposes a cost-effective cloud-based architecture using an event-driven backbone to process many applications\u2019 data in real-time, called REDA. It supports the Amazon Web Service (AWS) IoT core, and it opens the door as a free software-based implementation. Measured data from several wireless sensor nodes are transmitted to the cloud running application through the lightweight publisher\/subscriber messaging transport protocol, MQTT. The real-time stream processing platform, Apache Kafka, is used as a message broker to receive data from the producer and forward it to the correspondent consumer. Micro-services design patterns, as an event consumer, are implemented with Java spring and managed with Apache Maven to avoid the monolithic applications\u2019 problem. The Apache Kafka cluster co-located with Zookeeper is deployed over three availability zones and optimized for high throughput and low latency. To guarantee no message loss and to simulate the system performances, different load tests are carried out. The proposed architecture is reliable in stress cases and can handle records goes to 8000 messages in a second with low latency in a cheap hosted and configured architecture.<\/jats:p>","DOI":"10.1007\/s11227-021-03955-6","type":"journal-article","created":{"date-parts":[[2021,7,26]],"date-time":"2021-07-26T20:03:28Z","timestamp":1627329808000},"page":"3374-3401","update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":60,"title":["Design and implementation of a cloud-based event-driven architecture for real-time data processing in wireless sensor networks"],"prefix":"10.1007","volume":"78","author":[{"ORCID":"https:\/\/orcid.org\/0000-0002-0562-0116","authenticated-orcid":false,"given":"Sabrine","family":"Khriji","sequence":"first","affiliation":[]},{"given":"Yahia","family":"Benbelgacem","sequence":"additional","affiliation":[]},{"given":"Rym","family":"Ch\u00e9our","sequence":"additional","affiliation":[]},{"given":"Dhouha El","family":"Houssaini","sequence":"additional","affiliation":[]},{"given":"Olfa","family":"Kanoun","sequence":"additional","affiliation":[]}],"member":"297","published-online":{"date-parts":[[2021,7,26]]},"reference":[{"key":"3955_CR1","doi-asserted-by":"publisher","first-page":"314","DOI":"10.1007\/s11227-018-02729-x","volume":"75","author":"A Mukherjee","year":"2019","unstructured":"Mukherjee A, Roy DG, De D (2019) Mobility-aware task delegation model in mobile cloud computing. J Supercomput 75:314\u2013339. https:\/\/doi.org\/10.1007\/s11227-018-02729-x","journal-title":"J Supercomput"},{"key":"3955_CR2","doi-asserted-by":"publisher","first-page":"1897","DOI":"10.1007\/s11227-020-03325-8","volume":"77","author":"MA Talib","year":"2021","unstructured":"Talib MA, Majzoub S, Nasir Q et al (2021) A systematic literature review on hardware implementation of artificial intelligence algorithms. J Supercomput 77:1897\u20131938. https:\/\/doi.org\/10.1007\/s11227-020-03325-8","journal-title":"J Supercomput"},{"key":"3955_CR3","doi-asserted-by":"publisher","first-page":"317","DOI":"10.1007\/s11227-015-1565-y","volume":"72","author":"G Baranwal","year":"2016","unstructured":"Baranwal G, Vidyarthi DP (2016) Admission control in cloud computing using game theory. J Supercomput 72:317\u2013346. https:\/\/doi.org\/10.1007\/s11227-015-1565-y","journal-title":"J Supercomput"},{"key":"3955_CR4","doi-asserted-by":"publisher","first-page":"6401","DOI":"10.1007\/s11227-018-2652-7","volume":"74","author":"DS Park","year":"2018","unstructured":"Park DS (2018) Future computing with IoT and cloud computing. J Supercomput 74:6401\u20136407. https:\/\/doi.org\/10.1007\/s11227-018-2652-7","journal-title":"J Supercomput"},{"key":"3955_CR5","unstructured":"Cerwall P, Jonsson P, M\u00f6ller R, B\u00e4vertoft S, Carson S, Godor, I Ericsson mobility report, On the Pulse of the Net1030 worked Society. Hg. v. Ericsson"},{"issue":"10","key":"3955_CR6","doi-asserted-by":"publisher","first-page":"873","DOI":"10.1177\/0037549718759432","volume":"94","author":"R Ch\u00e9our","year":"2018","unstructured":"Ch\u00e9our R, Jmal MW, Abid M (2018) New combined method for low energy consumption in wireless sensor network applications. Simulation 94(10):873\u201385. https:\/\/doi.org\/10.1177\/0037549718759432","journal-title":"Simulation"},{"key":"3955_CR7","doi-asserted-by":"publisher","DOI":"10.1515\/9783110445053-017","author":"S Khriji","year":"2018","unstructured":"Khriji S, Houssaini DE, Kammoun I, Kanoun O (2018) Energy-efficient techniques in wireless sensor networks: technology, components and system design. Energy Harvest Wirel Sensor Netw. https:\/\/doi.org\/10.1515\/9783110445053-017","journal-title":"Energy Harvest Wirel Sensor Netw"},{"issue":"10","key":"3955_CR8","doi-asserted-by":"publisher","first-page":"28","DOI":"10.1109\/MAES.2019.2901134","volume":"34","author":"R Ch\u00e9our","year":"2019","unstructured":"Ch\u00e9our R, Khriji S, El Houssaini D, Baklouti M, Abid M, Kanoun O (2019) Recent trends of FPGA used for low-power wireless sensor network. IEEE Aerosp Electron Syst Mag 34(10):28\u201338","journal-title":"IEEE Aerosp Electron Syst Mag"},{"key":"3955_CR9","doi-asserted-by":"publisher","DOI":"10.1007\/978-3-030-00247-3_12","volume-title":"Ad-hoc, mobile, and wireless networks.","author":"S Khriji","year":"2018","unstructured":"Khriji S, Houssaini DE, Kammoun I, Kanoun O (2018) A fuzzy based energy aware unequal clustering for wireless sensor networks. In: Montavont N, Papadopoulos G (eds) Ad-hoc, mobile, and wireless networks., vol 11104. Springer, Cham (ADHOC-NOW 2018. Lecture Notes in Computer Science)"},{"key":"3955_CR10","doi-asserted-by":"crossref","unstructured":"Ch\u00e9our R, Khriji S, Kanoun O (2020) Microcontrollers for IoT: optimizations, computing paradigms, and future directions. In: 2020 IEEE 6th World Forum on Internet of Things (WF-IoT) pp 1-7. IEEE","DOI":"10.1109\/WF-IoT48130.2020.9221219"},{"key":"3955_CR11","doi-asserted-by":"publisher","first-page":"9493","DOI":"10.1007\/s11227-020-03213-1","volume":"76","author":"H Tabrizchi","year":"2020","unstructured":"Tabrizchi H, Kuchaki Rafsanjani M (2020) A survey on security challenges in cloud computing: issues, threats, and solutions. J Supercomput 76:9493\u20139532. https:\/\/doi.org\/10.1007\/s11227-020-03213-1","journal-title":"J Supercomput"},{"key":"3955_CR12","doi-asserted-by":"publisher","first-page":"6994","DOI":"10.1007\/s11227-019-03134-8","volume":"76","author":"C Li","year":"2020","unstructured":"Li C, Bai J, Luo Y (2020) Efficient resource scaling based on load fluctuation in edge-cloud computing environment. J Supercomput 76:6994\u20137025. https:\/\/doi.org\/10.1007\/s11227-019-03134-8","journal-title":"J Supercomput"},{"key":"3955_CR13","doi-asserted-by":"crossref","unstructured":"Mihai V, Dragana C, Stamatescu G, Popescu D, Ichim L, 2018 Wireless sensor network architecture based on fog computing. In: 2018 5th International Conference on Control, Decision and Information Technologies (CoDIT), Thessaloniki, Greece, 10-13 April . IEEE (2018), pp 743-747. https:\/\/doi.org\/10.1109\/CoDIT.2018.8394851","DOI":"10.1109\/CoDIT.2018.8394851"},{"key":"3955_CR14","doi-asserted-by":"publisher","first-page":"489","DOI":"10.1007\/s11227-018-2706-x","volume":"75","author":"CH Hsu","year":"2019","unstructured":"Hsu CH, Fox G, Min G et al (2019) Advances in big data programming, system software and HPC convergence. J Supercomput 75:489\u2013493. https:\/\/doi.org\/10.1007\/s11227-018-2706-x","journal-title":"J Supercomput"},{"issue":"5","key":"3955_CR15","doi-asserted-by":"publisher","first-page":"616","DOI":"10.1016\/J.ENG.2017.05.015","volume":"3","author":"RY Zhong","year":"2017","unstructured":"Zhong RY, Xu X, Klotz E, Newman ST (2017) Intelligent manufacturing in the context of industry 4.0: a review. Engineering 3(5):616\u2013630. https:\/\/doi.org\/10.1016\/J.ENG.2017.05.015","journal-title":"Engineering"},{"issue":"7","key":"3955_CR16","doi-asserted-by":"publisher","first-page":"1645","DOI":"10.1016\/j.future.2013.01.010","volume":"29","author":"J Gubbi","year":"2013","unstructured":"Gubbi J, Buyya R, Marusic S, Palaniswami M (2013) Internet of Things (IoT): a vision, architectural elements, and future directions. Future Gener Comput Syst 29(7):1645\u20131660. https:\/\/doi.org\/10.1016\/j.future.2013.01.010","journal-title":"Future Gener Comput Syst"},{"key":"3955_CR17","doi-asserted-by":"publisher","first-page":"1001","DOI":"10.1007\/s10586-016-0573-x","volume":"19","author":"D Seo","year":"2016","unstructured":"Seo D, Jeon YB, Lee SH et al (2016) Cloud computing for ubiquitous computing on M2M and IoT environment mobile application. Cluster Comput 19:1001\u20131013. https:\/\/doi.org\/10.1007\/s10586-016-0573-x","journal-title":"Cluster Comput"},{"key":"3955_CR18","doi-asserted-by":"crossref","unstructured":"Zhou C, Zhang X (2014) Toward the internet of things application and management: a practical approach. In: 2014 Proceeding of IEEE International Symposium on a World of Wireless, Mobile and Multimedia Networks, Sydney, NSW, Australia, 19 June 2014. IEEE , pp 1-6. https:\/\/doi.org\/10.1109\/WoWMoM.2014.6918928","DOI":"10.1109\/WoWMoM.2014.6918928"},{"key":"3955_CR19","doi-asserted-by":"publisher","unstructured":"Chenaru O, Stamatescu G, Stamatescu I, Towards Popescu D, cloud integration for industrial wireless sensor network systems. In: 2015 9th International Symposium on Advanced Topics in Electrical Engineering (ATEE), Bucharest, Romania, 7\u20139 May 2015. IEEE 2015:917\u2013922. https:\/\/doi.org\/10.1109\/ATEE.2015.7133933","DOI":"10.1109\/ATEE.2015.7133933"},{"key":"3955_CR20","unstructured":"Kurniawan A (2018) Learning AWS IoT: effectively manage connected devices on the AWS cloud using services such as AWS Greengrass, AWS button, predictive analytics and machine learning. Packt Publishing Ltd"},{"key":"3955_CR21","doi-asserted-by":"publisher","first-page":"633","DOI":"10.1016\/j.future.2018.07.040","volume":"89","author":"Olaniyan Richard","year":"2018","unstructured":"Richard Olaniyan, Olamilekan Fadahunsi, Muthucumaru Maheswaran, Faten Zhani Mohamed (2018) Opportunistic edge computing: concepts, opportunities and research challenges. Future Gener Comput Syst 89:633\u2013645","journal-title":"Future Gener Comput Syst"},{"key":"3955_CR22","doi-asserted-by":"publisher","first-page":"831","DOI":"10.1016\/j.future.2017.05.005","volume":"87","author":"O\u2019Loughlin John","year":"2018","unstructured":"John O\u2019Loughlin, Lee Gillam (2018) A performance brokerage for heterogeneous clouds. Future Gener Comput Syst 87:831\u2013845","journal-title":"Future Gener Comput Syst"},{"key":"3955_CR23","doi-asserted-by":"publisher","first-page":"223","DOI":"10.1016\/j.future.2019.04.037","volume":"100","author":"De F la Prieta","year":"2019","unstructured":"la Prieta De F, Rodr\u00edguez-Gonz\u00e1lez S, Chamoso P, Corchado JM, Bajo J (2019) Survey of agent-based cloud computing applications. Future Gener Comput Syst 100:223\u2013236","journal-title":"Future Gener Comput Syst"},{"issue":"1","key":"3955_CR24","doi-asserted-by":"publisher","first-page":"191","DOI":"10.3390\/app11010191","volume":"11","author":"A Pogiatzis","year":"2021","unstructured":"Pogiatzis A, Samakovitis G (2021) An event-driven serverless ETL pipeline on AWS. Appl Sci 11(1):191","journal-title":"Appl Sci"},{"key":"3955_CR25","doi-asserted-by":"publisher","DOI":"10.1007\/978-3-642-19724-6_1","volume-title":"Reasoning in event-based distributed systems","author":"S Helmer","year":"2011","unstructured":"Helmer S, Poulovassilis A, Xhafa F (2011) Introduction to reasoning in event-based distributed systems. In: Helmer S, Poulovassilis A, Xhafa F (eds) Reasoning in event-based distributed systems, vol 347. Springer, Berlin, Heidelberg (Studies in Computational Intelligence)"},{"key":"3955_CR26","doi-asserted-by":"crossref","unstructured":"Bruns R, Dunkel J (2010) Event-driven architecture: Softwarearchitektur f\u00fcr ereignisgesteuerte Gesch\u00e4ftsprozesse. Springer-Verlag","DOI":"10.1007\/978-3-642-02439-9"},{"issue":"10","key":"3955_CR27","doi-asserted-by":"publisher","first-page":"385","DOI":"10.3390\/ijgi7100385","volume":"7","author":"M Rieke","year":"2018","unstructured":"Rieke M, Bigagli L, Herle S, Jirka S, Kotsev A, Liebig T, Malewski C, Paschke T, Stasch C (2018) Geospatial IoT\u2014the need for event-driven architectures in contemporary spatial data Infrastructures. ISPRS Int J Geo Inf 7(10):385. https:\/\/doi.org\/10.3390\/ijgi7100385","journal-title":"ISPRS Int J Geo Inf"},{"key":"3955_CR28","doi-asserted-by":"publisher","unstructured":"Yassein MB, Shatnawi MQ, Aljwarneh S, Internet Al-Hatmi R (2017) Internet of Things: Survey and open issues of MQTT protocol. In: 2017 International Conference on Engineering & MIS (ICEMIS), Monastir, Tunisia, 8\u201310 May 2017. IEEE 2017:1\u20136. https:\/\/doi.org\/10.1109\/ICEMIS.2017.8273112","DOI":"10.1109\/ICEMIS.2017.8273112"},{"key":"3955_CR29","unstructured":"Soni D, Makwana A (2017) A survey on MQTT: a protocol of internet of things (IoT). In: International Conference on Telecommunication, Power Analysis and Computing Techniques (ICTPACT-2017), Bharath Institute of Higher Education and Research, 173, Agharam Road, Selaiyur, Chennai, India"},{"key":"3955_CR30","doi-asserted-by":"publisher","unstructured":"Philippe D, Kyumars SE (2017) Kafka versus RabbitMQ: a comparative study of two industry reference publish\/subscribe implementations: Industry Paper. In: Proceedings of the 11th ACM International Conference on Distributed and Event-based Systems (DEBS \u201917). Association for Computing Machinery, New York, NY, USA, pp 227-238. https:\/\/doi.org\/10.1145\/3093742.3093908","DOI":"10.1145\/3093742.3093908"},{"key":"3955_CR31","unstructured":"John V, Liu X (2017) A survey of distributed message broker queues. arXiv preprint arXiv:1704.00411"},{"key":"3955_CR32","first-page":"1","volume":"11","author":"J Kreps","year":"2011","unstructured":"Kreps J, Narkhede N, Rao J (2011) Kafka: a distributed messaging system for log processing. Proc NetDB 11:1\u20137","journal-title":"Proc NetDB"},{"key":"3955_CR33","unstructured":"Newman S 2015. Building microservices: designing fine-grained systems. O\u2019Reilly Media, Inc"},{"key":"3955_CR34","doi-asserted-by":"publisher","unstructured":"Popi\u0107 S, Pezer D, Mrazovac B, Tesli\u0107 N (2016) Performance evaluation of using Protocol Buffers in the Internet of Things communication. In: 2016 International Conference on Smart Systems and Technologies (SST), Osijek, Croatia, 12-14 Oct. 2016. IEEE , pp 261-265. https:\/\/doi.org\/10.1109\/SST.2016.7765670","DOI":"10.1109\/SST.2016.7765670"},{"key":"3955_CR35","doi-asserted-by":"publisher","unstructured":"Maeda K (2012) Performance evaluation of object serialization libraries in XML, JSON and binary formats. In: 2012 Second International Conference on Digital Information and Communication Technology and it\u2019s Applications (DICTAP), Bangkok, Thailand, 16-18 May 2012. IEEE , pp 177-182. https:\/\/doi.org\/10.1109\/DICTAP.2012.6215346","DOI":"10.1109\/DICTAP.2012.6215346"},{"key":"3955_CR36","unstructured":"Karagiannis V (2014) Building a Testbed for the Internet of Things. Alexander Technological Educational Institute of Thessaloniki 1\u201392"},{"key":"3955_CR37","volume-title":"Women in precision agriculture","author":"S Khriji","year":"2021","unstructured":"Khriji S, El Houssaini D, Kammoun I, Kanoun O (2021) Precision irrigation: an IoT-enabled wireless sensor network for smart irrigation systems. In: Hamrita T (ed) Women in precision agriculture. Springer, Cham (Women in Engineering and Science)"},{"key":"3955_CR38","doi-asserted-by":"publisher","unstructured":"Khriji S, Kallel AY, Reedy S, El Houssaini D, Kammoun I, Kanoun O (2019) Dynamic autonomous energy consumption measurement for a wireless sensor node. In, (2019) IEEE International Symposium on Measurements & Networking (M&N), Catania, Italy. 8\u201310 July 2019. IEEE 2019:1\u20135. https:\/\/doi.org\/10.1109\/IWMN.2019.8805001","DOI":"10.1109\/IWMN.2019.8805001"},{"key":"3955_CR39","volume-title":"Event processing in action","author":"O Etzion","year":"2011","unstructured":"Etzion O, Niblett P (2011) Event processing in action. Simon and Schuster, New York City"},{"key":"3955_CR40","unstructured":"Apache kafka streams documentation, https:\/\/kafka.apache.org\/documentation\/streams\/, access (January 2021)"},{"key":"3955_CR41","volume-title":"MongoDB: the definitive guide: powerful and scalable data storage","author":"K Chodorow","year":"2013","unstructured":"Chodorow K (2013) MongoDB: the definitive guide: powerful and scalable data storage. O\u2019Reilly Media Inc, Sebastopol"},{"issue":"13","key":"3955_CR42","doi-asserted-by":"publisher","first-page":"265","DOI":"10.21105\/joss.00265","volume":"2","author":"RA Light","year":"2017","unstructured":"Light RA (2017) Mosquitto: server and client implementation of the MQTT protocol. Int J Open Source Softw Process https:\/\/ 2(13):265. https:\/\/doi.org\/10.21105\/joss.00265","journal-title":"Int J Open Source Softw Process"}],"container-title":["The Journal of Supercomputing"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s11227-021-03955-6.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/article\/10.1007\/s11227-021-03955-6\/fulltext.html","content-type":"text\/html","content-version":"vor","intended-application":"text-mining"},{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/s11227-021-03955-6.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2022,2,7]],"date-time":"2022-02-07T13:13:37Z","timestamp":1644239617000},"score":1,"resource":{"primary":{"URL":"https:\/\/link.springer.com\/10.1007\/s11227-021-03955-6"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2021,7,26]]},"references-count":42,"journal-issue":{"issue":"3","published-print":{"date-parts":[[2022,2]]}},"alternative-id":["3955"],"URL":"https:\/\/doi.org\/10.1007\/s11227-021-03955-6","relation":{},"ISSN":["0920-8542","1573-0484"],"issn-type":[{"value":"0920-8542","type":"print"},{"value":"1573-0484","type":"electronic"}],"subject":[],"published":{"date-parts":[[2021,7,26]]},"assertion":[{"value":"17 June 2021","order":1,"name":"accepted","label":"Accepted","group":{"name":"ArticleHistory","label":"Article History"}},{"value":"26 July 2021","order":2,"name":"first_online","label":"First Online","group":{"name":"ArticleHistory","label":"Article History"}}]}}