常见问题
通用
FlowMQ 是什么？
FlowMQ 是新一代高性能统一消息与流处理平台，在单一平台中原生支持 MQTT、Kafka 和 AMQP 协议。它将消息队列、数据流和发布/订阅消息传递融合为一套统一系统，消除了管理多个专用 Broker 的复杂性。
FlowMQ 与 Kafka、RabbitMQ 有何区别？
FlowMQ 结合了两者的优势：
- 类似 Kafka：提供持久化、可重放的 Stream（流），支持消费者管理偏移量，适合事件溯源和流处理。
- 类似 RabbitMQ：提供 Queue（队列），消息投递给消费者，消费确认后删除。
FlowMQ 的目标是在更简单的运维模型和统一 API 下，同时提供这两种模型的能力。
概念
Topic、Queue 和 Stream 有什么区别？
- Topic（主题）：消息发布的路由地址。客户端可以直接从 Topic 消费，也可以通过 Queue 或 Stream 来接收消息。
- Queue（队列）：提供消息队列语义：消息先缓存到队列中，再按需投递给消费者，消费确认（ACK）后删除。
- Stream（流）：持久化、有序的消息日志。多个消费者（组）可以独立读取同一个 Stream，各自追踪偏移量。消息不会因读取而删除，根据保留策略过期。适合发布/订阅、事件溯源、可重放的事件历史。
什么时候用 Queue，什么时候用 Stream？
- Queue：当你需要将任务分发给一组 Worker，确保每个任务只被处理一次（如请求处理、图像缩放等）。
- Stream：当你需要将消息广播给多个独立消费者，或需要持久化的可重放事件历史（如用户行为追踪、金融行情、审计日志等）。
消费者未确认 (ack) Queue 中的消息会怎样？
如果消费者收到消息后崩溃或断连，FlowMQ 不会认为该消息已处理。超过可配置的超时时间后，FlowMQ 会将消息重新投递给其他可用的消费者，确保消息不会丢失。
消息持久化保证是什么？
发布到 FlowMQ 的消息会在写入磁盘后才向生产者返回确认，即使 Broker 重启也不会丢失消息。