{"id":1641,"date":"2026-06-07T10:52:24","date_gmt":"2026-06-07T08:52:24","guid":{"rendered":"https:\/\/www.rocworks.at\/wordpress\/?p=1641"},"modified":"2026-06-07T10:52:24","modified_gmt":"2026-06-07T08:52:24","slug":"%f0%9f%9a%80-sunday-feature-monstermq-goes-kafka","status":"publish","type":"post","link":"https:\/\/www.rocworks.at\/wordpress\/?p=1641","title":{"rendered":"\ud83d\ude80 Sunday Feature: MonsterMQ goes Kafka!"},"content":{"rendered":"\n<p class=\"wp-block-paragraph\">A new experimental feature has landed in MonsterMQ: It is acting now as a Kafka Broker, so a Kafka Client can subscribe (and publish, if allowed) to streams. Streams are mapped to MQTT topics. So MQTT topic value changes are going into those streams.<\/p>\n\n\n\n<p class=\"wp-block-paragraph\">Before anyone asks: No, this is not a replacement for Apache Kafka. \ud83d\ude42<\/p>\n\n\n\n<p class=\"wp-block-paragraph\">The queueing is currently backed by databases such as PostgreSQL, MongoDB, and SQLite, so it won\u2019t compete with Kafka in terms of throughput and scalability.<\/p>\n\n\n\n<p class=\"wp-block-paragraph\">But for many smaller and medium-sized use cases, it brings streaming concepts directly into the broker:<\/p>\n\n\n\n<ul class=\"wp-block-list\">\n\n<li>\ud83d\udd39 MQTT and Kafka-style messaging in one server<\/li>\n\n\n<li>\ud83d\udd39 Persistent queues stored in a database<\/li>\n\n\n<li>\ud83d\udd39 Simple deployment without additional infrastructure<\/li>\n\n\n<li>\ud83d\udd39 Easy integration with the existing MonsterMQ ecosystem<\/li>\n\n<\/ul>\n\n\n\n<p class=\"wp-block-paragraph\">As always, this is a first draft &#8211; not yet in the version or docker image!<\/p>\n\n\n\n<p class=\"wp-block-paragraph\">Feedback is welcome!<\/p>\n\n\n\n<figure class=\"wp-block-image size-large\"><img loading=\"lazy\" decoding=\"async\" width=\"800\" height=\"533\" src=\"https:\/\/www.rocworks.at\/wordpress\/wp-content\/uploads\/2026\/06\/MonsterMQ-Kafka-0.jpeg\" alt=\"MonsterMQ-Kafka-0\" class=\"wp-image-1638\" srcset=\"https:\/\/www.rocworks.at\/wordpress\/wp-content\/uploads\/2026\/06\/MonsterMQ-Kafka-0.jpeg 800w, https:\/\/www.rocworks.at\/wordpress\/wp-content\/uploads\/2026\/06\/MonsterMQ-Kafka-0-300x200.jpeg 300w, https:\/\/www.rocworks.at\/wordpress\/wp-content\/uploads\/2026\/06\/MonsterMQ-Kafka-0-768x512.jpeg 768w\" sizes=\"auto, (max-width: 800px) 100vw, 800px\" \/><\/figure>\n\n\n\n<figure class=\"wp-block-image size-large\"><img loading=\"lazy\" decoding=\"async\" width=\"2560\" height=\"1360\" src=\"https:\/\/www.rocworks.at\/wordpress\/wp-content\/uploads\/2026\/06\/MonsterMQ-Kafka-1-scaled.png\" alt=\"MonsterMQ-Kafka-1\" class=\"wp-image-1639\" srcset=\"https:\/\/www.rocworks.at\/wordpress\/wp-content\/uploads\/2026\/06\/MonsterMQ-Kafka-1-scaled.png 2560w, https:\/\/www.rocworks.at\/wordpress\/wp-content\/uploads\/2026\/06\/MonsterMQ-Kafka-1-300x159.png 300w, https:\/\/www.rocworks.at\/wordpress\/wp-content\/uploads\/2026\/06\/MonsterMQ-Kafka-1-1024x544.png 1024w, https:\/\/www.rocworks.at\/wordpress\/wp-content\/uploads\/2026\/06\/MonsterMQ-Kafka-1-768x408.png 768w, https:\/\/www.rocworks.at\/wordpress\/wp-content\/uploads\/2026\/06\/MonsterMQ-Kafka-1-1536x816.png 1536w, https:\/\/www.rocworks.at\/wordpress\/wp-content\/uploads\/2026\/06\/MonsterMQ-Kafka-1-2048x1088.png 2048w\" sizes=\"auto, (max-width: 2560px) 100vw, 2560px\" \/><\/figure>\n\n\n\n<figure class=\"wp-block-image size-large\"><img loading=\"lazy\" decoding=\"async\" width=\"2560\" height=\"1781\" src=\"https:\/\/www.rocworks.at\/wordpress\/wp-content\/uploads\/2026\/06\/MonsterMQ-Kafka-2-scaled.png\" alt=\"MonsterMQ-Kafka-2\" class=\"wp-image-1640\" srcset=\"https:\/\/www.rocworks.at\/wordpress\/wp-content\/uploads\/2026\/06\/MonsterMQ-Kafka-2-scaled.png 2560w, https:\/\/www.rocworks.at\/wordpress\/wp-content\/uploads\/2026\/06\/MonsterMQ-Kafka-2-300x209.png 300w, https:\/\/www.rocworks.at\/wordpress\/wp-content\/uploads\/2026\/06\/MonsterMQ-Kafka-2-1024x712.png 1024w, https:\/\/www.rocworks.at\/wordpress\/wp-content\/uploads\/2026\/06\/MonsterMQ-Kafka-2-768x534.png 768w, https:\/\/www.rocworks.at\/wordpress\/wp-content\/uploads\/2026\/06\/MonsterMQ-Kafka-2-1536x1069.png 1536w, https:\/\/www.rocworks.at\/wordpress\/wp-content\/uploads\/2026\/06\/MonsterMQ-Kafka-2-2048x1425.png 2048w\" sizes=\"auto, (max-width: 2560px) 100vw, 2560px\" \/><\/figure>\n\n\n\n<p class=\"wp-block-paragraph\"><a href=\"https:\/\/MonsterMQ.com\">\ud83d\udc49 MonsterMQ.com<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"<p>A new experimental feature has landed in MonsterMQ: It is acting now as a Kafka Broker, so a Kafka Client can subscribe (and publish, if allowed) to streams. Streams are mapped to MQTT topics. So MQTT topic value changes are &hellip; <a href=\"https:\/\/www.rocworks.at\/wordpress\/?p=1641\">Continue reading <span class=\"meta-nav\">&rarr;<\/span><\/a><\/p>\n","protected":false},"author":1,"featured_media":1638,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-1641","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-allgemein"],"_links":{"self":[{"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/1641","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=1641"}],"version-history":[{"count":1,"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/1641\/revisions"}],"predecessor-version":[{"id":1643,"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/1641\/revisions\/1643"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=\/wp\/v2\/media\/1638"}],"wp:attachment":[{"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=1641"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=1641"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=1641"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}