示例代码中的参数说明如下，请参考收集连接信息获取参数值。 bootstrap_servers：实例连接地址与端口。 topic_name：Topic名称。 consumer_id：消费组名称。根据业务需求，自定义消费组名称，如果设置的消费组不存在，Kafka会自动创建。 执行以下命令，运行消费消息的代码示例。

查看更多 →

Kafka默认用户组 用户组名称 描述 kafkaadmin Kafka管理员用户组。添加入本组的用户，拥有所有主题的创建，删除，授权及读写权限。 kafkasuperuser Kafka高级用户组。添加入本组的用户，拥有所有主题的读写权限。 kafka Kafka普通用户组。添加入本组

查看更多 →

在左侧导航栏选择“消费组管理”，进入消费组列表页面。 消费组列表页面显示消费组名称、消费组状态、Coordinator (ID)和描述。Coordinator (ID)显示的数字表示Coordinator组件所在的代理，消费组的状态如下。 DEAD：消费组内没有任何成员，且没有任何元数据。

查看更多 →

Hue中的输入框输入中文会出现混乱 用户问题 Hue中的输入框输入中文会出现混乱。 问题现象 Hue的输入框中输入中文时，会出现混乱，第一次输入不了的情况，也即输入的中文会首先出现英文，中文并未输入，再次输入会带上之前的内容，示例如下： 原因分析 Hue对中文的处理存在混乱的情况，需要进行修正。

查看更多 →

在左侧导航栏选择“消费组管理”，进入消费组列表页面。 通过以下任意一种方法，删除消费组。 勾选消费组名称左侧的方框，可选一个或多个，单击信息栏左上侧的“删除消费组”。 在待删除消费组所在行，单击“删除”。 仅在“消费组状态”为“EMPTY”时，支持删除。 消费组包含以下状态： DE

查看更多 →

35); Kafka作为source表时必须指定“properties.group.id”配置项 【示例】以“testGroup”为用户组读取主题为“test_sink”的Kafka消息： CREATE TABLE KafkaSource( `user_id` VARCHAR

查看更多 →

示例列表 注册/注册组 认证类型 策略类型 示例 注册 证书认证 证书策略 MQTT X.509证书认证设备使用证书策略发放示例 注册 密钥认证 静态策略 MQTT 密钥设备使用静态策略发放示例 注册组 证书认证 自定义策略 MQTT 注册组自定义策略发放示例 注册组 云证书认证 证书策略

查看更多 →

示例代码中的参数说明，可参考获取MQS连接信息获取参数值。 BootstrapServers：MQS连接地址和端口。 GroupId：消费组名称。根据业务需要，自定义消费组名称，如果设置的消费组不存在，系统会自动创建。 topic：要消费消息的Topic名称。 SaslUsername和SaslPassw

查看更多 →

在顶部导航栏单击“Consumers”，进入消费组列表页面。 图2 导航栏 单击待查看消费者连接地址的消费组名称，进入消费组订阅的Topic列表页面。 图3 消费组列表页面 单击待查看消费者连接地址的Topic名称，进入Topic详情页。 图4 消费组订阅的Topic列表页面 在“Consumer

查看更多 →

必选 String 对应设备接入实例的接入地址。 initConfig 必选 String 客户在创建设备，或者创建注册组时自定义的初始化Json字符串。 示例 设备先订阅Topic后才能收到命令推送，设备接收到的payload: { "address": "10.0

查看更多 →

在Kafka控制台的“消费组管理”页面，单击待查看堆积消息的消费组名称，进入消费组详情页。在“消费进度”页签，查看消费组中每个Topic的总堆积数。具体步骤，请参考查看消费者信息。 在Kafka控制台的“监控”页面的“消费组”页签中，“消费组”选择待查看堆积消息数的消费组名称，“队列”选择

查看更多 →

选择左侧导航栏的“故障通报 > 通知组管理”，进入通知组管理页面。 单击“添加”。 填写通知组名称、备注，并在组内成员后的输入框输入成员账号名，并单击“单次添加”，可重复输入并添加多个成员。如图1所示，然后单击“确定”。 通知组添加完成后，会显示在通知组列表中，可以查看该通知组成员状态。

查看更多 →

选择左侧导航栏的“故障通报 > 通知组管理”，进入通知组管理页面。 单击“添加”。 填写通知组名称、备注，并在组内成员后的输入框输入成员账号名，并单击“单次添加”，可重复输入并添加多个成员。如图1所示，然后单击“确定”。 通知组添加完成后，会显示在通知组列表中，可以查看该通知组成员状态。

查看更多 →

“test”添加 “test” 主题的“生产”权限。 前提条件 已安装Ranger服务且服务运行正常。 已创建用户需要配置权限的用户、用户组或Role。 操作步骤 使用Ranger管理员用户rangeradmin登录Ranger管理页面，具体操作可参考登录Ranger WebUI界面。

查看更多 →

“test”添加 “test” 主题的“生产”权限。 前提条件 已安装Ranger服务且服务运行正常。 已创建用户需要配置权限的用户、用户组或Role。 操作步骤 使用Ranger管理员用户rangeradmin登录Ranger管理页面，具体操作可参考登录Ranger WebUI界面。

查看更多 →

将钉钉机器人的Webhook填入相应的输入框中。 将秘钥或是自定义关键词填入相应的输入框中，确认无误后单击“确定”保存配置。 创建告警通知组并添加告警通知对象 创建告警通知组，并将通知对象加入到通知组中。 具体操作请参考创建通知对象/通知组。 创建告警规则 创建告警规则，用户可配

查看更多 →

-[0-9]*)' connector.properties.bootstrap.servers 是 kafka brokers地址，以逗号分隔。 connector.properties.group.id 否 消费组名称 connector.startup-mode 否 con

查看更多 →

专享版页面。 单击Kafka实例的名称，进入实例详情页面。 在左侧导航栏选择“消费组管理”，进入消费组列表页面。 单击待查看消费进度的消费组名称，进入消费组详情页。 在“消费进度”页签，查看此消费组订阅的Topic列表、Topic中消息的总堆积数、Topic每个分区的消费进度（包

查看更多 →

-[0-9]*)' connector.properties.bootstrap.servers 是 kafka brokers地址，以逗号分隔。 connector.properties.group.id 否 消费组名称 connector.startup-mode 否 con

查看更多 →

筛选条件：对关联表单数据进行过滤筛选，获取满足条件的数据。 单击“筛选条件”下方的“设置条件组”，设置筛选条件组名。 支持创建多组条件组，每一组支持添加多个筛选条件。 支持设置组与组之间的关系，关系包含“且”和“或”。 单击筛选条件组名下方的“设置条件”，设置筛选条件。 图2 设置筛选条件 表1 设置筛选条件

查看更多 →

筛选条件：对关联表单数据进行过滤筛选，获取满足条件的数据。 单击“筛选条件”下方的“设置条件组”，设置筛选条件组名。 支持创建多组条件组，每一组支持添加多个筛选条件。 支持设置组与组之间的关系，关系包含“且”和“或”。 单击筛选条件组名下方的“设置条件”，设置筛选条件。 图2 设置筛选条件 表1 设置筛选条件

查看更多 →