{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2025,3,25]],"date-time":"2025-03-25T22:08:47Z","timestamp":1742940527246,"version":"3.40.3"},"publisher-location":"Singapore","reference-count":16,"publisher":"Springer Nature Singapore","isbn-type":[{"type":"print","value":"9789819922321"},{"type":"electronic","value":"9789819922338"}],"license":[{"start":{"date-parts":[[2023,1,1]],"date-time":"2023-01-01T00:00:00Z","timestamp":1672531200000},"content-version":"tdm","delay-in-days":0,"URL":"https:\/\/www.springernature.com\/gp\/researchers\/text-and-data-mining"},{"start":{"date-parts":[[2023,1,1]],"date-time":"2023-01-01T00:00:00Z","timestamp":1672531200000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/www.springernature.com\/gp\/researchers\/text-and-data-mining"}],"content-domain":{"domain":["link.springer.com"],"crossmark-restriction":false},"short-container-title":[],"published-print":{"date-parts":[[2023]]},"DOI":"10.1007\/978-981-99-2233-8_29","type":"book-chapter","created":{"date-parts":[[2023,4,30]],"date-time":"2023-04-30T03:18:45Z","timestamp":1682824725000},"page":"410-417","update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":1,"title":["Optimizing Data Stream Throughput for Real-Time Applications"],"prefix":"10.1007","author":[{"given":"Kusuma","family":"Amilineni","sequence":"first","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Po-Yen","family":"Hsu","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Ching-Hsien","family":"Hsu","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Hojjat","family":"Baghban","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Wen-Thong","family":"Chang","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]},{"given":"Nithin Melala","family":"Eshwarappa","sequence":"additional","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"297","published-online":{"date-parts":[[2023,5,1]]},"reference":[{"key":"29_CR1","unstructured":"Sagarkar, M., et al.: A Study of distributed event streaming & publish-subscribe systems"},{"key":"29_CR2","doi-asserted-by":"crossref","unstructured":"Das, T., et al.: Adaptive stream processing using dynamic batch sizing. In: Proceedings of the ACM Symposium on Cloud Computing (2014)","DOI":"10.1145\/2670979.2670995"},{"key":"29_CR3","unstructured":"John, V., Liu, X.: A survey of distributed message broker queues. arXiv preprint arXiv:1704.00411 (2017)"},{"issue":"2","key":"29_CR4","first-page":"33","volume":"35","author":"K Goodhope","year":"2012","unstructured":"Goodhope, K., et al.: Building linkedin\u2019s real-time activity data pipeline. IEEE Data Eng. Bull. 35(2), 33\u201345 (2012)","journal-title":"IEEE Data Eng. Bull."},{"key":"29_CR5","unstructured":"Kreps, J., Narkhede, N., Rao, J.: Kafka: a distributed messaging system for log processing. In: Proceedings of the NetDB. vol. 11 (2011)"},{"key":"29_CR6","doi-asserted-by":"crossref","unstructured":"Wang, G., et al.: Building a replicated logging system with Apache Kafka. In: Proceedings of the VLDB Endowment, vol. 8, no. 12, pp. 1654\u20131655 (2015)","DOI":"10.14778\/2824032.2824063"},{"key":"29_CR7","doi-asserted-by":"crossref","unstructured":"Dobbelaere, P., Esmaili, K.S.: 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 (2017)","DOI":"10.1145\/3093742.3093908"},{"key":"29_CR8","doi-asserted-by":"crossref","unstructured":"Hiraman, B.R.: A study of apache kafka in big data stream processing. In: 2018 International Conference on Information, Communication, Engineering and Technology (ICICET). IEEE (2018)","DOI":"10.1109\/ICICET.2018.8533771"},{"key":"29_CR9","doi-asserted-by":"crossref","unstructured":"Langhi, S., Tommasini, R., Della Valle, E.: Extending kafka streams for complex event recognition. In: 2020 IEEE International Conference on Big Data (Big Data). IEEE (2020)","DOI":"10.1109\/BigData50022.2020.9378217"},{"key":"29_CR10","doi-asserted-by":"crossref","unstructured":"Le Noac\u2019H, P., Costan, A., Boug\u00e9, L.: A performance evaluation of Apache Kafka in support of big data streaming applications. In: 2017 IEEE International Conference on Big Data (Big Data). IEEE (2017)","DOI":"10.1109\/BigData.2017.8258548"},{"key":"29_CR11","doi-asserted-by":"crossref","unstructured":"Tun, M.T., Nyaung, D.E., Phyu, M.P.: Performance evaluation of intrusion detection streaming transactions using apache kafka and spark streaming. In: 2019 International Conference on Advanced Information Technologies (ICAIT). IEEE (2019)","DOI":"10.1109\/AITC.2019.8920960"},{"key":"29_CR12","doi-asserted-by":"crossref","unstructured":"Ramalingam, G., Vaswani, K.: Fault tolerance via idempotence. In: Proceedings of the 40th Annual ACM SIGPLAN-SIGACT symposium on principles of programming languages (2013)","DOI":"10.1145\/2429069.2429100"},{"key":"29_CR13","doi-asserted-by":"crossref","unstructured":"Raptis, T.P., Passarella, A.: On efficiently partitioning a topic in Apache Kafka. arXiv preprint arXiv:2205.09415 (2022)","DOI":"10.1109\/CITS55221.2022.9832981"},{"key":"29_CR14","doi-asserted-by":"crossref","unstructured":"Wu, H., et al.: A reactive batching strategy of apache kafka for reliable stream processing in real-time. In: 2020 IEEE 31st International Symposium on Software Reliability Engineering (ISSRE). IEEE (2020)","DOI":"10.1109\/ISSRE5003.2020.00028"},{"key":"29_CR15","doi-asserted-by":"crossref","unstructured":"Wu, H., Shang, Z., Wolter, K.: Performance prediction for the Apache Kafka messaging system. In: 2019 IEEE 21st International Conference on High Performance Computing and Communications; IEEE 17th International Conference on Smart City; IEEE 5th International Conference on Data Science and Systems (HPCC\/SmartCity\/DSS). IEEE (2019)","DOI":"10.1109\/HPCC\/SmartCity\/DSS.2019.00036"},{"key":"29_CR16","doi-asserted-by":"publisher","first-page":"99","DOI":"10.1016\/j.procs.2018.08.242","volume":"136","author":"R Wiatr","year":"2018","unstructured":"Wiatr, R., S\u0142ota, R., Kitowski, J.: Optimizing Kafka for stream processing in latency sensitive systems. Procedia Comput. Sci. 136, 99\u2013108 (2018)","journal-title":"Procedia Comput. Sci."}],"container-title":["Lecture Notes in Computer Science","Big Data Intelligence and Computing"],"original-title":[],"language":"en","link":[{"URL":"https:\/\/link.springer.com\/content\/pdf\/10.1007\/978-981-99-2233-8_29","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2023,4,30]],"date-time":"2023-04-30T03:23:28Z","timestamp":1682825008000},"score":1,"resource":{"primary":{"URL":"https:\/\/link.springer.com\/10.1007\/978-981-99-2233-8_29"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2023]]},"ISBN":["9789819922321","9789819922338"],"references-count":16,"URL":"https:\/\/doi.org\/10.1007\/978-981-99-2233-8_29","relation":{},"ISSN":["0302-9743","1611-3349"],"issn-type":[{"type":"print","value":"0302-9743"},{"type":"electronic","value":"1611-3349"}],"subject":[],"published":{"date-parts":[[2023]]},"assertion":[{"value":"1 May 2023","order":1,"name":"first_online","label":"First Online","group":{"name":"ChapterHistory","label":"Chapter History"}},{"value":"DataCom","order":1,"name":"conference_acronym","label":"Conference Acronym","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"International Conference on Big Data Intelligence and Computing","order":2,"name":"conference_name","label":"Conference Name","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"Denarau","order":3,"name":"conference_city","label":"Conference City","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"Fiji","order":4,"name":"conference_country","label":"Conference Country","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"2022","order":5,"name":"conference_year","label":"Conference Year","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"8 December 2022","order":7,"name":"conference_start_date","label":"Conference Start Date","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"10 December 2022","order":8,"name":"conference_end_date","label":"Conference End Date","group":{"name":"ConferenceInfo","label":"Conference Information"}},{"value":"datacom2022","order":10,"name":"conference_id","label":"Conference ID","group":{"name":"ConferenceInfo","label":"Conference Information"}}]}}