emqx/flowsdk

View on GitHub

A safety-first, behavior-predictable MQTT 5.0 SDK written in Rust.

Stars: 21
Forks: 6
Open beginner issues: 0
Indexed issues: 17
Avg merge: 3h 5m
Merged PRs (30d): 1

Dominant language: Rust
License: MPL-2.0
Last GitHub push: Sep 10, 2026
Latest indexed: Sep 15, 2026
Contributing guide: Contributing guide
Code of conduct: No code of conduct
Beginner labels: No beginner labels indexed

Open All

17 open issues indexed

Doc: project structure Open

emqx/flowsdk#1 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Doc: MQTT session mgmt Open

emqx/flowsdk#6 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
test: integration test with EMQX Open

emqx/flowsdk#8 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
dev: msg deliver mgmt api design Open

emqx/flowsdk#9 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
MQTT stream integration Open

emqx/flowsdk#16 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
MQTT Batch Publishing Open

emqx/flowsdk#19 · 0 comments · 1 reaction · 1 assignee · Indexed Sep 15, 2026
This error condition should use ParseError::BufferTooShort instead of ParseError::More. The ParseError::More variant expects different parameters and semantics for incomplete data scenarios. Open

emqx/flowsdk#28 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
MQTT Server support (not broker) Open

emqx/flowsdk#57 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
websocket support Open

emqx/flowsdk#63 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
QUIC engine, avoid use clone Open

emqx/flowsdk#65 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Add doc for state transverse diagrams Open

emqx/flowsdk#74 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
[FEATURE] cust mqtt v5 or v3 only. Open

enhancement

emqx/flowsdk#85 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
[FEATURE] disallow session resume (cleanstart=false) if suback isn't received. Open

enhancement

emqx/flowsdk#86 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
[FEATURE] A2A transport Open

enhancement

emqx/flowsdk#90 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
[FEATURE] build in YOCTO Open

enhancement

emqx/flowsdk#91 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
zephyr support Open

emqx/flowsdk#102 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
[DOC] determinism analysis Open

enhancement

emqx/flowsdk#112 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026

emqx/flowsdk

Get new issues in your inbox