{"updated":"2025-01-19T12:24:28.121986+00:00","metadata":{"_oai":{"id":"oai:ipsj.ixsq.nii.ac.jp:00226766","sets":["1164:4088:11174:11292"]},"path":["11292"],"owner":"44499","recid":"226766","title":["Apache Kafkaを用いたMQTTブローカーの耐障害性向上と性能評価"],"pubdate":{"attribute_name":"公開日","attribute_value":"2023-06-27"},"_buckets":{"deposit":"3947e38c-5833-49e2-b617-64508afcb60b"},"_deposit":{"id":"226766","pid":{"type":"depid","value":"226766","revision_id":0},"owners":[44499],"status":"published","created_by":44499},"item_title":"Apache Kafkaを用いたMQTTブローカーの耐障害性向上と性能評価","author_link":["602864","602865"],"item_titles":{"attribute_name":"タイトル","attribute_value_mlt":[{"subitem_title":"Apache Kafkaを用いたMQTTブローカーの耐障害性向上と性能評価"}]},"item_keyword":{"attribute_name":"キーワード","attribute_value_mlt":[{"subitem_subject":"分散・ブロックチェーン","subitem_subject_scheme":"Other"}]},"item_type_id":"4","publish_date":"2023-06-27","item_4_text_3":{"attribute_name":"著者所属","attribute_value_mlt":[{"subitem_text_value":"トヨタ自動車株式会社"},{"subitem_text_value":"トヨタ自動車株式会社"}]},"item_4_text_4":{"attribute_name":"著者所属(英)","attribute_value_mlt":[{"subitem_text_value":"Toyota Motor Corporation","subitem_text_language":"en"},{"subitem_text_value":"Toyota Motor Corporation","subitem_text_language":"en"}]},"item_language":{"attribute_name":"言語","attribute_value_mlt":[{"subitem_language":"jpn"}]},"item_publisher":{"attribute_name":"出版者","attribute_value_mlt":[{"subitem_publisher":"情報処理学会","subitem_publisher_language":"ja"}]},"publish_status":"0","weko_shared_id":-1,"item_file_price":{"attribute_name":"Billing file","attribute_type":"file","attribute_value_mlt":[{"url":{"url":"https://ipsj.ixsq.nii.ac.jp/record/226766/files/IPSJ-IOT23062002.pdf","label":"IPSJ-IOT23062002.pdf"},"date":[{"dateType":"Available","dateValue":"2025-06-27"}],"format":"application/pdf","billing":["billing_file"],"filename":"IPSJ-IOT23062002.pdf","filesize":[{"value":"2.0 MB"}],"mimetype":"application/pdf","priceinfo":[{"tax":["include_tax"],"price":"660","billingrole":"5"},{"tax":["include_tax"],"price":"330","billingrole":"6"},{"tax":["include_tax"],"price":"0","billingrole":"43"},{"tax":["include_tax"],"price":"0","billingrole":"44"}],"accessrole":"open_date","version_id":"8f05393a-733f-4b21-892b-ac31c578e544","displaytype":"detail","licensetype":"license_note","license_note":"Copyright (c) 2023 by the Information Processing Society of Japan"}]},"item_4_creator_5":{"attribute_name":"著者名","attribute_type":"creator","attribute_value_mlt":[{"creatorNames":[{"creatorName":"岡田, 和也"}],"nameIdentifiers":[{}]},{"creatorNames":[{"creatorName":"阿部, 博"}],"nameIdentifiers":[{}]}]},"item_4_source_id_9":{"attribute_name":"書誌レコードID","attribute_value_mlt":[{"subitem_source_identifier":"AA12326962","subitem_source_identifier_type":"NCID"}]},"item_4_textarea_12":{"attribute_name":"Notice","attribute_value_mlt":[{"subitem_textarea_value":"SIG Technical Reports are nonrefereed and hence may later appear in any journals, conferences, symposia, etc."}]},"item_resource_type":{"attribute_name":"資源タイプ","attribute_value_mlt":[{"resourceuri":"http://purl.org/coar/resource_type/c_18gh","resourcetype":"technical report"}]},"item_4_source_id_11":{"attribute_name":"ISSN","attribute_value_mlt":[{"subitem_source_identifier":"2188-8787","subitem_source_identifier_type":"ISSN"}]},"item_4_description_7":{"attribute_name":"論文抄録","attribute_value_mlt":[{"subitem_description":"IoT デバイスの普及に伴い，デバイスが生成するデータをリアルタイムに処理・蓄積・解析する大規模データ処理基盤が重要になっている．現在，多くの大規模データ処理基盤にてデバイスからのデータ収集に Publisher/Subscriber（Pub/Sub）方式のプロトコルである MQTT が広く採用されている．MQTT のクライアント，ブローカの実装は商用・オープンソースともに複数存在しており，主要なパブリッククラウドにおいても各種 MQTT サービスが展開されている．一方で，MQTT においてデータを中継するブローカの構成，処理性能，耐障害性は実装よってさまざまである．基盤構築時には，用途，単位時間あたりのメッセージ数などに応じて実装を選択することが肝要である．例えば代表的なブローカー実装の一つである Mosquitto では，ブローカーインスタンス間の冗長構成が取れない．そのため，障害発生時にはメッセージが失われてしまう．本報告では，Mosquitto ブローカーにストリーム処理基盤の一つである Apache Kafka クラスタを組み合わせることによる耐障害性の向上について報告する．評価では．AWS 上に構築した実験環境を用いて，Apache Kafka を用いない場合と用いる場合でのメッセージ処理数の差，エンドツーエンドでの遅延の分布・違い，ブローカーでの障害発生時の動作を評価した．評価の結果，Apache Kafka を用いることで AWS 上の EC2 インスタンス 3 台で 99,000 クライアントからのメッセージを処理し，ブローカーインスタンスの障害発生時にもメッセージを損失することなく転送できることを確認した．","subitem_description_type":"Other"}]},"item_4_biblio_info_10":{"attribute_name":"書誌情報","attribute_value_mlt":[{"bibliographicPageEnd":"6","bibliographic_titles":[{"bibliographic_title":"研究報告インターネットと運用技術（IOT）"}],"bibliographicPageStart":"1","bibliographicIssueDates":{"bibliographicIssueDate":"2023-06-27","bibliographicIssueDateType":"Issued"},"bibliographicIssueNumber":"2","bibliographicVolumeNumber":"2023-IOT-62"}]},"relation_version_is_last":true,"weko_creator_id":"44499"},"created":"2025-01-19T01:26:05.658072+00:00","id":226766,"links":{}}