消息管理（MQTT/KAFKA）
Kafka
Kafka是一种消息队列服务，用于在IoT平台中传输和管理消息。通过Kafka，IoT平台可以监控服务器上的Kafka消息，提供查询功能，并监控主题、代理和消费组的相关信息。
主题：
在IOT平台中，您可以执行以下主题操作：
- 统计 Kafka 服务中的主题数量：这个操作允许您统计当前 Kafka 服务中的主题数量以及主题的相关信息。
- 自定义拉取特定主题下的消息或向某个主题下发消息：通过这个操作，您可以自定义拉取特定主题下的消息或向某个主题下发消息。
主题信息查询：
自定义拉取数据：
参数解释：
| 参数 | 描述 |
|---|---|
| Partition（分区） | Kafka主题被分为多个分区，每个分区是消息的逻辑容器，用于并行处理消息。分区允许数据水平扩展，提高吞吐量和并发性。 |
| Auto Offset Reset（自动偏移量重置） | 这是一个消费者配置选项，用于确定当一个消费者加入一个消费组并开始消费主题的分区时，从哪个偏移开始消费消息。可选项包括：earliest（最早）、latest（最新）、none。 |
| Offset（偏移量） | 在Kafka中，每个分区中的每条消息都有一个唯一的偏移量，表示消息在分区内的位置。消费者通过跟踪每个分区的当前偏移量来确定从哪里开始消费消息。偏移量可以手动提交或由Kafka代理自动管理。 |
| Count（数量） | 用于控制查询的消息数量。 |
| Key（键） | Kafka消息可以包含一个可选的键，通常是一个字符串，用于标识消息。键可用于将消息路由到特定的分区，以维护消息的有序性和分区级别的消息处理。 |
| Value（值） | Kafka消息的实际内容，通常是任何字节序列，包括要传递的数据，如日志条目或事件。 |
下发消息：
IOT平台还支持向指定分区下发包含键值（Key-Value）的消息。
Kafka代理（Broker）状态：
您可以查看当前运行的Kafka代理的状态。
消费组（Consumer Group）信息：
您可以查看服务器上Kafka的消费组信息。
MQTT
IoT平台提供了对服务器上MQTT服务的资源以及运行状态的监控，简单客户端维护，主题查看，订阅客户端查看等功能。
监控：
可以监控当前MQTT在服务器上的CPU、内存使用情况，以及MQTT服务端的状态监控，同时可以查看MQTT的服务端版本。
客户端管理：
可以查询当前连接的客户端信息，并提供手动下线指定客户端的功能。
主题：
可以查看当前存在的主题列表。
订阅：
可以查看当前客户端对MQTT主题的订阅情况。