{"id":2994,"date":"2021-04-16T06:26:39","date_gmt":"2021-04-16T06:26:39","guid":{"rendered":"https:\/\/waterstream.io\/?p=2994"},"modified":"2025-09-30T12:48:19","modified_gmt":"2025-09-30T12:48:19","slug":"what-if-the-waterstream-node-goes-down","status":"publish","type":"post","link":"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/","title":{"rendered":"What if the Waterstream node goes down?"},"content":{"rendered":"\t\t
\n\t\t\t\t
\n\t\t\t\t\t
\n\t\t\t\t
\n\t\t\t\t
\n\t\t\t\t\t\t\t\t\t\t\t\t\t\t\t\"\"\t\t\t\t\t\t\t\t\t\t\t\t\t\t\t<\/div>\n\t\t\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t\t\t<\/div>\n\t\t\t\t
\n\t\t\t\t\t\t
\n\t\t\t\t\t
\n\t\t\t
\n\t\t\t\t\t\t
\n\t\t\t\t
\n\t\t\t\t\t\t\t\t\t

If you’ve ever wondered how Waterstream cluster behaves if one of its members goes down – here are some tests we’ve done.<\/p>\n

The test setup consists of Kafka provided by\u00a0Confluent Cloud<\/a>, 5 nodes of Waterstream and a load balancer running on\u00a0Google Cloud Platform<\/a>, and 5 nodes of\u00a0MQTT load simulator<\/a>\u00a0– also on GCP.<\/p>\n

The scripts we used for creating topics in Confluent Cloud and for running Waterstream in Google Cloud are here:\u00a0<\/span>https:\/\/github.com\/simplematter\/waterstream-gcp-terraform<\/a>. This setup has a single Kafka topic for MQTT messages with 10 partitions (in Confluent Cloud cluster capacity depends on number of partitions). For Waterstream deployment, we’ve used 5 n1-standard-1 nodes (1 CPU, 3.75 GB RAM). A separate VM hosts Prometheus and Grafana, which we’re going to use for monitoring Waterstream behavior during a simulated node failure.<\/span><\/p>\n

The scripts we used for creating topics in Confluent Cloud and for running Waterstream in Google Cloud are here:\u00a0<\/span>https:\/\/github.com\/simplematter\/waterstream-gcp-terraform<\/a>. This setup has a single Kafka topic for MQTT messages with 10 partitions (in Confluent Cloud cluster capacity depends on number of partitions). For Waterstream deployment, we’ve used 5 n1-standard-1 nodes (1 CPU, 3.75 GB RAM). A separate VM hosts Prometheus and Grafana, which we’re going to use for monitoring Waterstream behavior during a simulated node failure.\u00a0<\/span>MQTT load generator also has scripts for launching it on <\/span>Google Cloud.<\/a><\/p>\n

We’ve configured it to run 5 nodes on the same machine type – n1-standard-1. Each node spawns 20k clients with ramp-up time 120 seconds. Together that makes 100k clients. When ramp-up completes, each clients sends 0.8… 1.2 KB QoS 2 (exactly once) PUBLISH message every 10 seconds. Clean Session flag for all the clients is\u00a0false<\/code>, so that we could also test the loading of the session data upon client reconnect.<\/p>\n

Having all this infrastructure started, we’ve waited few minutes to see all the clients connected and produce messages and expected.\u00a0<\/p>\t\t\t\t\t\t\t\t<\/div>\n\t\t\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t<\/section>\n\t\t\t\t

\n\t\t\t\t\t\t
\n\t\t\t\t\t
\n\t\t\t
\n\t\t\t\t\t\t
\n\t\t\t\t
\n\t\t\t\t\t\t\t\t\t\t\t\t
\n\t\t\t\t\t\t\t\t\t\t\"\"\t\t\t\t\t\t\t\t\t\t\t
The load simulator before stopping a node - see the red line<\/figcaption>\n\t\t\t\t\t\t\t\t\t\t<\/figure>\n\t\t\t\t\t\t\t\t\t<\/div>\n\t\t\t\t<\/div>\n\t\t\t\t
\n\t\t\t\t
\n\t\t\t\t\t\t\t\t\t\t\t\t
\n\t\t\t\t\t\t\t\t\t\t\"\"\t\t\t\t\t\t\t\t\t\t\t
Waterstream connected clients before stopping a node - see the red line<\/figcaption>\n\t\t\t\t\t\t\t\t\t\t<\/figure>\n\t\t\t\t\t\t\t\t\t<\/div>\n\t\t\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t<\/section>\n\t\t\t\t
\n\t\t\t\t\t\t
\n\t\t\t\t\t
\n\t\t\t
\n\t\t\t\t\t\t
\n\t\t\t\t
\n\t\t\t\t\t\t\t\t\t

Then we opened a console of one of the Waterstream nodes and shut down the Docker container of the Waterstream and<\/span>\u00a0watch Waterstream Grafana dashboard to see the effect:<\/span><\/p>\t\t\t\t\t\t\t\t<\/div>\n\t\t\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t<\/section>\n\t\t\t\t

\n\t\t\t\t\t\t
\n\t\t\t\t\t
\n\t\t\t
\n\t\t\t\t\t\t
\n\t\t\t\t
\n\t\t\t\t\t\t\t\t\t\t\t\t
\n\t\t\t\t\t\t\t\t\t\t\"\"\t\t\t\t\t\t\t\t\t\t\t
Waterstream rebalancing the load of survivor nodes - see the red line<\/figcaption>\n\t\t\t\t\t\t\t\t\t\t<\/figure>\n\t\t\t\t\t\t\t\t\t<\/div>\n\t\t\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t<\/section>\n\t\t\t\t
\n\t\t\t\t\t\t
\n\t\t\t\t\t
\n\t\t\t
\n\t\t\t\t\t\t
\n\t\t\t\t
\n\t\t\t\t\t\t\t\t\t

As you can see, after a while clients started to notice that connections are broken and they need to re-connect. 1 minute 45 seconds after the start of the simulated incident all the clients have successfully connected to the survivor nodes. Looking at the connection details in the Load Simulator Waterstream dashboard we can see that there were 19.9k connections with the node that went down and that there were some unsuccessful attempts to re-connect while the load balancer hadn’t yet detected the node failure:<\/p>\t\t\t\t\t\t\t\t<\/div>\n\t\t\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t<\/section>\n\t\t\t\t

\n\t\t\t\t\t\t
\n\t\t\t\t\t
\n\t\t\t
\n\t\t\t\t\t\t
\n\t\t\t\t
\n\t\t\t\t\t\t\t\t\t\t\t\t
\n\t\t\t\t\t\t\t\t\t\t\"\"\t\t\t\t\t\t\t\t\t\t\t
The load simulator shows restoring clients on the survivor Waterstream nodes - see the red line<\/figcaption>\n\t\t\t\t\t\t\t\t\t\t<\/figure>\n\t\t\t\t\t\t\t\t\t<\/div>\n\t\t\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t<\/section>\n\t\t\t\t
\n\t\t\t\t\t\t
\n\t\t\t\t\t
\n\t\t\t
\n\t\t\t\t\t\t
\n\t\t\t\t
\n\t\t\t\t\t\t\t\t\t

<\/p>\n

<\/p>\n

<\/p>\n

<\/figure>\n

And here is the part of the Waterstream dashboard that shows the session loading metrics. You may see that it has successfully loaded existing sessions for the clients that were re-connecting.<\/span><\/p>\n

<\/p>\t\t\t\t\t\t\t\t<\/div>\n\t\t\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t<\/section>\n\t\t\t\t

\n\t\t\t\t\t\t
\n\t\t\t\t\t
\n\t\t\t
\n\t\t\t\t\t\t
\n\t\t\t\t
\n\t\t\t\t\t\t\t\t\t\t\t\t\t\t\t\"\"\t\t\t\t\t\t\t\t\t\t\t\t\t\t\t<\/div>\n\t\t\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t<\/section>\n\t\t\t\t
\n\t\t\t\t\t\t
\n\t\t\t\t\t
\n\t\t\t
\n\t\t\t\t\t\t
\n\t\t\t\t
\n\t\t\t\t\t\t\t\t\t

As the tests are complete, shut down load generator and Waterstream, and remove topics from Confluent Cloud to stop being charged.<\/p>\n

\u00a0<\/p>\n

\u00a0<\/p>\n

This test demonstrates how survivor Waterstream nodes may take over the load of the failed one, keep the cluster running and client sessions available. If you want to repeat these tests yourselves you can ask evaluation license\u00a0here<\/a>\u00a0and get support on\u00a0our forum<\/a>.<\/p>\n

Enjoy your IoT!<\/p>\n

Author: Paul Lysak<\/em><\/p>\t\t\t\t\t\t\t\t<\/div>\n\t\t\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t<\/div>\n\t\t\t\t\t<\/div>\n\t\t<\/section>\n\t\t\t\t<\/div>\n\t\t","protected":false},"excerpt":{"rendered":"

If you’ve ever wondered how Waterstream cluster behaves if one of its members goes down – here are some tests we’ve done. The test setup consists of Kafka provided by\u00a0Confluent Cloud, 5 nodes of Waterstream and a load balancer running on\u00a0Google Cloud Platform, and 5 nodes of\u00a0MQTT load simulator\u00a0– also on GCP. The scripts we […]<\/p>\n","protected":false},"author":2,"featured_media":5994,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"content-type":"","ocean_post_layout":"","ocean_both_sidebars_style":"","ocean_both_sidebars_content_width":0,"ocean_both_sidebars_sidebars_width":0,"ocean_sidebar":"0","ocean_second_sidebar":"0","ocean_disable_margins":"enable","ocean_add_body_class":"","ocean_shortcode_before_top_bar":"","ocean_shortcode_after_top_bar":"","ocean_shortcode_before_header":"","ocean_shortcode_after_header":"","ocean_has_shortcode":"","ocean_shortcode_after_title":"","ocean_shortcode_before_footer_widgets":"","ocean_shortcode_after_footer_widgets":"","ocean_shortcode_before_footer_bottom":"","ocean_shortcode_after_footer_bottom":"","ocean_display_top_bar":"default","ocean_display_header":"default","ocean_header_style":"","ocean_center_header_left_menu":"0","ocean_custom_header_template":"0","ocean_custom_logo":0,"ocean_custom_retina_logo":0,"ocean_custom_logo_max_width":0,"ocean_custom_logo_tablet_max_width":0,"ocean_custom_logo_mobile_max_width":0,"ocean_custom_logo_max_height":0,"ocean_custom_logo_tablet_max_height":0,"ocean_custom_logo_mobile_max_height":0,"ocean_header_custom_menu":"0","ocean_menu_typo_font_family":"0","ocean_menu_typo_font_subset":"","ocean_menu_typo_font_size":0,"ocean_menu_typo_font_size_tablet":0,"ocean_menu_typo_font_size_mobile":0,"ocean_menu_typo_font_size_unit":"px","ocean_menu_typo_font_weight":"","ocean_menu_typo_font_weight_tablet":"","ocean_menu_typo_font_weight_mobile":"","ocean_menu_typo_transform":"","ocean_menu_typo_transform_tablet":"","ocean_menu_typo_transform_mobile":"","ocean_menu_typo_line_height":0,"ocean_menu_typo_line_height_tablet":0,"ocean_menu_typo_line_height_mobile":0,"ocean_menu_typo_line_height_unit":"","ocean_menu_typo_spacing":0,"ocean_menu_typo_spacing_tablet":0,"ocean_menu_typo_spacing_mobile":0,"ocean_menu_typo_spacing_unit":"","ocean_menu_link_color":"","ocean_menu_link_color_hover":"","ocean_menu_link_color_active":"","ocean_menu_link_background":"","ocean_menu_link_hover_background":"","ocean_menu_link_active_background":"","ocean_menu_social_links_bg":"","ocean_menu_social_hover_links_bg":"","ocean_menu_social_links_color":"","ocean_menu_social_hover_links_color":"","ocean_disable_title":"default","ocean_disable_heading":"default","ocean_post_title":"","ocean_post_subheading":"","ocean_post_title_style":"","ocean_post_title_background_color":"","ocean_post_title_background":0,"ocean_post_title_bg_image_position":"","ocean_post_title_bg_image_attachment":"","ocean_post_title_bg_image_repeat":"","ocean_post_title_bg_image_size":"","ocean_post_title_height":0,"ocean_post_title_bg_overlay":0.5,"ocean_post_title_bg_overlay_color":"","ocean_disable_breadcrumbs":"default","ocean_breadcrumbs_color":"","ocean_breadcrumbs_separator_color":"","ocean_breadcrumbs_links_color":"","ocean_breadcrumbs_links_hover_color":"","ocean_display_footer_widgets":"default","ocean_display_footer_bottom":"default","ocean_custom_footer_template":"0","ocean_post_oembed":"","ocean_post_self_hosted_media":"","ocean_post_video_embed":"","ocean_link_format":"","ocean_link_format_target":"self","ocean_quote_format":"","ocean_quote_format_link":"post","ocean_gallery_link_images":"off","ocean_gallery_id":[],"footnotes":""},"categories":[10,16,11],"tags":[46,47,48],"class_list":["post-2994","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-kakfa","category-mqtt","category-technology","tag-mqtt-broker-kafka","tag-multi-node-mqtt-broker-kafka","tag-resilient-kafka-mqtt","entry","has-media"],"yoast_head":"\nWhat if the Waterstream node goes down? - Waterstream.io | Simplify MQTT Data Integration<\/title>\n<meta name=\"description\" content=\"How survivor Waterstream nodes (Mqtt Broker) may take over the load of the failed one, keep the cluster running and client sessions available.\" \/>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/\" \/>\n<meta property=\"og:locale\" content=\"it_IT\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"What if the Waterstream node goes down? - Waterstream.io | Simplify MQTT Data Integration\" \/>\n<meta property=\"og:description\" content=\"How survivor Waterstream nodes (Mqtt Broker) may take over the load of the failed one, keep the cluster running and client sessions available.\" \/>\n<meta property=\"og:url\" content=\"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/\" \/>\n<meta property=\"og:site_name\" content=\"Waterstream.io | Simplify MQTT Data Integration\" \/>\n<meta property=\"article:published_time\" content=\"2021-04-16T06:26:39+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2025-09-30T12:48:19+00:00\" \/>\n<meta property=\"og:image\" content=\"http:\/\/waterstream.io\/wp-content\/uploads\/2021\/04\/Waterstream-node.jpg\" \/>\n\t<meta property=\"og:image:width\" content=\"900\" \/>\n\t<meta property=\"og:image:height\" content=\"600\" \/>\n\t<meta property=\"og:image:type\" content=\"image\/jpeg\" \/>\n<meta name=\"author\" content=\"Waterstream\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"Scritto da\" \/>\n\t<meta name=\"twitter:data1\" content=\"Waterstream\" \/>\n\t<meta name=\"twitter:label2\" content=\"Tempo di lettura stimato\" \/>\n\t<meta name=\"twitter:data2\" content=\"4 minuti\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"Article\",\"@id\":\"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/#article\",\"isPartOf\":{\"@id\":\"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/\"},\"author\":{\"name\":\"Waterstream\",\"@id\":\"https:\/\/waterstream.io\/it\/#\/schema\/person\/c8471336c17e2ecc8c51e1d584b3ec47\"},\"headline\":\"What if the Waterstream node goes down?\",\"datePublished\":\"2021-04-16T06:26:39+00:00\",\"dateModified\":\"2025-09-30T12:48:19+00:00\",\"mainEntityOfPage\":{\"@id\":\"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/\"},\"wordCount\":590,\"publisher\":{\"@id\":\"https:\/\/waterstream.io\/it\/#organization\"},\"image\":{\"@id\":\"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/#primaryimage\"},\"thumbnailUrl\":\"https:\/\/waterstream.io\/wp-content\/uploads\/2021\/04\/Waterstream-node.jpg\",\"keywords\":[\"Mqtt Broker Kafka\",\"Multi Node Mqtt Broker Kafka\",\"Resilient Kafka Mqtt\"],\"articleSection\":[\"Kafka\",\"MQTT\",\"Technology\"],\"inLanguage\":\"it-IT\"},{\"@type\":\"WebPage\",\"@id\":\"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/\",\"url\":\"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/\",\"name\":\"What if the Waterstream node goes down? - Waterstream.io | Simplify MQTT Data Integration\",\"isPartOf\":{\"@id\":\"https:\/\/waterstream.io\/it\/#website\"},\"primaryImageOfPage\":{\"@id\":\"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/#primaryimage\"},\"image\":{\"@id\":\"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/#primaryimage\"},\"thumbnailUrl\":\"https:\/\/waterstream.io\/wp-content\/uploads\/2021\/04\/Waterstream-node.jpg\",\"datePublished\":\"2021-04-16T06:26:39+00:00\",\"dateModified\":\"2025-09-30T12:48:19+00:00\",\"description\":\"How survivor Waterstream nodes (Mqtt Broker) may take over the load of the failed one, keep the cluster running and client sessions available.\",\"breadcrumb\":{\"@id\":\"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/#breadcrumb\"},\"inLanguage\":\"it-IT\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/\"]}]},{\"@type\":\"ImageObject\",\"inLanguage\":\"it-IT\",\"@id\":\"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/#primaryimage\",\"url\":\"https:\/\/waterstream.io\/wp-content\/uploads\/2021\/04\/Waterstream-node.jpg\",\"contentUrl\":\"https:\/\/waterstream.io\/wp-content\/uploads\/2021\/04\/Waterstream-node.jpg\",\"width\":900,\"height\":600},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"Home\",\"item\":\"https:\/\/waterstream.io\/it\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"What if the Waterstream node goes down?\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/waterstream.io\/it\/#website\",\"url\":\"https:\/\/waterstream.io\/it\/\",\"name\":\"Waterstream.io | Simplify MQTT Data Integration\",\"description\":\"High performance MQTT Broker\",\"publisher\":{\"@id\":\"https:\/\/waterstream.io\/it\/#organization\"},\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/waterstream.io\/it\/?s={search_term_string}\"},\"query-input\":{\"@type\":\"PropertyValueSpecification\",\"valueRequired\":true,\"valueName\":\"search_term_string\"}}],\"inLanguage\":\"it-IT\"},{\"@type\":\"Organization\",\"@id\":\"https:\/\/waterstream.io\/it\/#organization\",\"name\":\"Waterstream.io | Simplify MQTT Data Integration\",\"url\":\"https:\/\/waterstream.io\/it\/\",\"logo\":{\"@type\":\"ImageObject\",\"inLanguage\":\"it-IT\",\"@id\":\"https:\/\/waterstream.io\/it\/#\/schema\/logo\/image\/\",\"url\":\"https:\/\/waterstream.io\/wp-content\/uploads\/2022\/05\/WaterStream-Logo-Color.png\",\"contentUrl\":\"https:\/\/waterstream.io\/wp-content\/uploads\/2022\/05\/WaterStream-Logo-Color.png\",\"width\":500,\"height\":117,\"caption\":\"Waterstream.io | Simplify MQTT Data Integration\"},\"image\":{\"@id\":\"https:\/\/waterstream.io\/it\/#\/schema\/logo\/image\/\"}},{\"@type\":\"Person\",\"@id\":\"https:\/\/waterstream.io\/it\/#\/schema\/person\/c8471336c17e2ecc8c51e1d584b3ec47\",\"name\":\"Waterstream\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"it-IT\",\"@id\":\"https:\/\/secure.gravatar.com\/avatar\/774b720bde6b29089269455bc31ecae3028eec39cff2333372e13d755f2f5391?s=96&d=mm&r=g\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/774b720bde6b29089269455bc31ecae3028eec39cff2333372e13d755f2f5391?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/774b720bde6b29089269455bc31ecae3028eec39cff2333372e13d755f2f5391?s=96&d=mm&r=g\",\"caption\":\"Waterstream\"},\"url\":\"https:\/\/waterstream.io\/it\/author\/waterstream\/\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"What if the Waterstream node goes down? - Waterstream.io | Simplify MQTT Data Integration","description":"How survivor Waterstream nodes (Mqtt Broker) may take over the load of the failed one, keep the cluster running and client sessions available.","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/","og_locale":"it_IT","og_type":"article","og_title":"What if the Waterstream node goes down? - Waterstream.io | Simplify MQTT Data Integration","og_description":"How survivor Waterstream nodes (Mqtt Broker) may take over the load of the failed one, keep the cluster running and client sessions available.","og_url":"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/","og_site_name":"Waterstream.io | Simplify MQTT Data Integration","article_published_time":"2021-04-16T06:26:39+00:00","article_modified_time":"2025-09-30T12:48:19+00:00","og_image":[{"width":900,"height":600,"url":"http:\/\/waterstream.io\/wp-content\/uploads\/2021\/04\/Waterstream-node.jpg","type":"image\/jpeg"}],"author":"Waterstream","twitter_card":"summary_large_image","twitter_misc":{"Scritto da":"Waterstream","Tempo di lettura stimato":"4 minuti"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"Article","@id":"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/#article","isPartOf":{"@id":"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/"},"author":{"name":"Waterstream","@id":"https:\/\/waterstream.io\/it\/#\/schema\/person\/c8471336c17e2ecc8c51e1d584b3ec47"},"headline":"What if the Waterstream node goes down?","datePublished":"2021-04-16T06:26:39+00:00","dateModified":"2025-09-30T12:48:19+00:00","mainEntityOfPage":{"@id":"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/"},"wordCount":590,"publisher":{"@id":"https:\/\/waterstream.io\/it\/#organization"},"image":{"@id":"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/#primaryimage"},"thumbnailUrl":"https:\/\/waterstream.io\/wp-content\/uploads\/2021\/04\/Waterstream-node.jpg","keywords":["Mqtt Broker Kafka","Multi Node Mqtt Broker Kafka","Resilient Kafka Mqtt"],"articleSection":["Kafka","MQTT","Technology"],"inLanguage":"it-IT"},{"@type":"WebPage","@id":"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/","url":"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/","name":"What if the Waterstream node goes down? - Waterstream.io | Simplify MQTT Data Integration","isPartOf":{"@id":"https:\/\/waterstream.io\/it\/#website"},"primaryImageOfPage":{"@id":"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/#primaryimage"},"image":{"@id":"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/#primaryimage"},"thumbnailUrl":"https:\/\/waterstream.io\/wp-content\/uploads\/2021\/04\/Waterstream-node.jpg","datePublished":"2021-04-16T06:26:39+00:00","dateModified":"2025-09-30T12:48:19+00:00","description":"How survivor Waterstream nodes (Mqtt Broker) may take over the load of the failed one, keep the cluster running and client sessions available.","breadcrumb":{"@id":"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/#breadcrumb"},"inLanguage":"it-IT","potentialAction":[{"@type":"ReadAction","target":["https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/"]}]},{"@type":"ImageObject","inLanguage":"it-IT","@id":"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/#primaryimage","url":"https:\/\/waterstream.io\/wp-content\/uploads\/2021\/04\/Waterstream-node.jpg","contentUrl":"https:\/\/waterstream.io\/wp-content\/uploads\/2021\/04\/Waterstream-node.jpg","width":900,"height":600},{"@type":"BreadcrumbList","@id":"https:\/\/waterstream.io\/it\/2021\/04\/16\/what-if-the-waterstream-node-goes-down\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"Home","item":"https:\/\/waterstream.io\/it\/"},{"@type":"ListItem","position":2,"name":"What if the Waterstream node goes down?"}]},{"@type":"WebSite","@id":"https:\/\/waterstream.io\/it\/#website","url":"https:\/\/waterstream.io\/it\/","name":"Waterstream.io | Simplify MQTT Data Integration","description":"High performance MQTT Broker","publisher":{"@id":"https:\/\/waterstream.io\/it\/#organization"},"potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/waterstream.io\/it\/?s={search_term_string}"},"query-input":{"@type":"PropertyValueSpecification","valueRequired":true,"valueName":"search_term_string"}}],"inLanguage":"it-IT"},{"@type":"Organization","@id":"https:\/\/waterstream.io\/it\/#organization","name":"Waterstream.io | Simplify MQTT Data Integration","url":"https:\/\/waterstream.io\/it\/","logo":{"@type":"ImageObject","inLanguage":"it-IT","@id":"https:\/\/waterstream.io\/it\/#\/schema\/logo\/image\/","url":"https:\/\/waterstream.io\/wp-content\/uploads\/2022\/05\/WaterStream-Logo-Color.png","contentUrl":"https:\/\/waterstream.io\/wp-content\/uploads\/2022\/05\/WaterStream-Logo-Color.png","width":500,"height":117,"caption":"Waterstream.io | Simplify MQTT Data Integration"},"image":{"@id":"https:\/\/waterstream.io\/it\/#\/schema\/logo\/image\/"}},{"@type":"Person","@id":"https:\/\/waterstream.io\/it\/#\/schema\/person\/c8471336c17e2ecc8c51e1d584b3ec47","name":"Waterstream","image":{"@type":"ImageObject","inLanguage":"it-IT","@id":"https:\/\/secure.gravatar.com\/avatar\/774b720bde6b29089269455bc31ecae3028eec39cff2333372e13d755f2f5391?s=96&d=mm&r=g","url":"https:\/\/secure.gravatar.com\/avatar\/774b720bde6b29089269455bc31ecae3028eec39cff2333372e13d755f2f5391?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/774b720bde6b29089269455bc31ecae3028eec39cff2333372e13d755f2f5391?s=96&d=mm&r=g","caption":"Waterstream"},"url":"https:\/\/waterstream.io\/it\/author\/waterstream\/"}]}},"_links":{"self":[{"href":"https:\/\/waterstream.io\/it\/wp-json\/wp\/v2\/posts\/2994","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/waterstream.io\/it\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/waterstream.io\/it\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/waterstream.io\/it\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/waterstream.io\/it\/wp-json\/wp\/v2\/comments?post=2994"}],"version-history":[{"count":0,"href":"https:\/\/waterstream.io\/it\/wp-json\/wp\/v2\/posts\/2994\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/waterstream.io\/it\/wp-json\/wp\/v2\/media\/5994"}],"wp:attachment":[{"href":"https:\/\/waterstream.io\/it\/wp-json\/wp\/v2\/media?parent=2994"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/waterstream.io\/it\/wp-json\/wp\/v2\/categories?post=2994"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/waterstream.io\/it\/wp-json\/wp\/v2\/tags?post=2994"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}