协议支持总览

FlowMQ 原生支持多种标准消息协议，在同一套集群与权限体系下提供一致的发布/订阅与流式处理能力。

MQTT

FlowMQ 提供完整的 MQTT 3.1.1 与 MQTT 5.0 支持：

• 实时 Pub/Sub
• QoS 0 / 1 / 2
• 遗嘱消息（LWT）、保留消息（Retained）
• MQTT 5.0 属性（Properties）、用户属性（User Properties）
• 主题通配符订阅（+ / #）
• TLS/SSL 加密传输

默认端口：1883（TCP）/ 8883（TLS）

关于如何使用 MQTT 协议访问 FlowMQ, 参考MQTT 协议

Kafka

FlowMQ 提供完整的 Kafka 协议兼容，可直接使用标准 Kafka 客户端接入：

• 高吞吐生产与消费
• Topic / Partition
• 幂等 Producer
• Consumer Group 以及 偏移量（Offset）提交与管理
• SASL/TLS 安全认证

默认端口：9092

关于如何使用 Kafka 客户端访问 FlowMQ, 参考 Kafka 协议

AMQP（开发中）

FlowMQ 对 AMQP 0-9-1 和 AMQP 1.0 支持还处在开发阶段，功能尚未完全可用。

• 交换机（Exchange）类型：Direct / Topic / Fanout
• 队列（Queue）声明与绑定（Binding）
• 持久化队列、消息确认（ACK）
• 消息属性与 TTL

默认端口：5672

详见：AMQP 协议