Integrate/MQTT: Coreflux, HiveMQ, Mosquitto

[amotl]

About

• Discriminate between HiveMQ vs. Mosquitto MQTT brokers
• Add basic walkthrough about HiveMQ
• Add section about Coreflux, including basic walkthrough

Preview

• https://cratedb-guide--526.org.readthedocs.build/integrate/mqtt/
• https://cratedb-guide--526.org.readthedocs.build/integrate/coreflux/
• https://cratedb-guide--526.org.readthedocs.build/integrate/hivemq/
• https://cratedb-guide--526.org.readthedocs.build/integrate/mosquitto/

[coderabbitai]

Walkthrough

Adds broker-specific MQTT integration docs (Coreflux, HiveMQ, Mosquitto) with Docker Compose examples and usage guides demonstrating publishing via MQTT, relaying with LorryStream, and ingesting into CrateDB; updates the main MQTT landing page to surface these integrations.

Changes

Cohort / File(s)	Summary
Coreflux Integration docs/integrate/coreflux/index.md, docs/integrate/coreflux/usage.md, docs/integrate/coreflux/compose.yaml	New Coreflux landing page, usage guide with Docker/Podman steps and examples, and a compose file defining cratedb, coreflux, mosquitto, lorrystream.
HiveMQ Integration docs/integrate/hivemq/index.md, docs/integrate/hivemq/usage.md, docs/integrate/hivemq/compose.yaml	New HiveMQ landing page, usage guide with compose orchestration (CrateDB healthcheck/profile), publish/relay examples, and CrateDB verification steps.
Mosquitto Integration docs/integrate/mosquitto/index.md, docs/integrate/mosquitto/usage.md, docs/integrate/mosquitto/compose.yaml	New Mosquitto landing page and usage (renamed to mosquitto-specific examples/queries); minor header comment URL fix in compose file.
MQTT Landing / Index docs/integrate/mqtt/index.md	Reworked MQTT index to highlight multiple brokers, add LorryStream synopsis, and link to broker-specific guides (Coreflux, HiveMQ, Mosquitto).

Sequence Diagram(s)

sequenceDiagram
    participant Publisher as Publisher (mqtt-pub)
    participant Broker as MQTT Broker (Coreflux/HiveMQ/Mosquitto)
    participant Lorry as LorryStream (MQTT source)
    participant Crate as CrateDB

    Publisher->>Broker: PUBLISH topic/json
    Broker->>Lorry: DELIVER message (subscriber)
    Lorry->>Crate: TRANSFORM & INSERT (HTTP/SQL)
    Crate-->>Lorry: ACK / insert result
    Lorry-->>Broker: optional PUB/SUB ack

Loading

Estimated code review effort

🎯 3 (Moderate) | ⏱️ ~22 minutes

Possibly related issues

• crate/crate-clients-tools#269 — Adds missing MQTT integration docs and compose examples under docs/integrate, aligning with the newly added broker guides.

Possibly related PRs

• Usage guides: Use {Docker,Podman} Compose where applicable #367 — Adds Compose-driven integration docs and compose examples; closely related to the compose/usage additions here.
• Integrate/MQTT: Add entry point page, micro tutorial, and category item #247 — Modifies MQTT tutorials and LorryStream onboarding; aligns with LorryStream usage content added.
• Layout NG: Folder structure and naming things #236 — Updates docs/integrate index structure; related to the main MQTT landing changes.

Suggested reviewers

• hammerhead
• seut
• surister

Poem

🐰 I hopped through docs with tiny feet,
Brought brokers, compose, and guides complete.
Coreflux, HiveMQ, Mosquitto in view,
LorryStream shuffles messages through.
CrateDB stores the tale anew. ✨

🚥 Pre-merge checks | ✅ 3

✅ Passed checks (3 passed)

Check name	Status	Explanation
Title check	✅ Passed	The title clearly summarizes the main change: adding integration documentation for three MQTT brokers (Coreflux, HiveMQ, and Mosquitto) to the MQTT integration guide.
Description check	✅ Passed	The description is directly related to the changeset, detailing the three main changes (discriminating between brokers, adding HiveMQ walkthrough, adding Coreflux section) and providing preview links.
Docstring Coverage	✅ Passed	No functions found in the changed files to evaluate docstring coverage. Skipping docstring coverage check.

_{✏️ Tip: You can configure your own custom pre-merge checks in the settings.}

✨ Finishing touches

🧪 Generate unit tests (beta)

• Create PR with unit tests
• Post copyable unit tests in a comment
• Commit unit tests in branch mqtt-more

---

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

• X
• Mastodon
• Reddit
• LinkedIn

_{Comment @coderabbitai help to get the list of available commands and usage tips.}

[hammerhead]

Thanks, good to have some initial exposure of these vendors/technologies.