StopTask 终止任务 SendTask 发送任务
broker-list kafka.bj.baidubce.com:9091 针对windows,发布命令如下: bin\windows\kafka-console-producer.bat --producer.config client.properties --topic <accountID>__demo --broker-list kafka.bj.baidubce.com:9091 消息发送以后
使用流程 如果需要使用mqtt工具查看下发的消息,请先参考 baetyl-broker配置 对边缘的mqtt broker进行配置,然后使用mqtt box等工具,连接上baetyl-broker,订阅想要接收的消息主题。 在节点的应用部署中,点击消息下发。 输入需要下发的topic,qos以及消息内容信息(当前格式化只支持json格式),点击发送。
操作步骤 登录 消息服务 for Kafka控制台 进入集群列表页面。 选择需要删除的集群,在右侧点击 删除 。 点击 删除 后,会弹出一个确认框,提示您将要删除的集群名称,如果您确认删除该集群,则点击 确定 按钮。 点击 确定 后,弹出安全验证框,点击 发送验证码 ,系统将验证码发送至您绑定的手机,请填写收到的验证码。
input.yml 步骤五:查看集群监控 查看消息是否发送成功或消费成功有两种方式: 在服务器端查看jar包运行日志。 在专享版消息服务 for Kafka控制台查看集群监控,获取集群生产、消息情况。 推荐使用第二种方式,下面介绍如何查看集群监控。 (1)在专享版消息服务 for Kafka的控制台页面找到需要连接的集群,点击集群名称进入 集群详情 页面。
接口类型 描述 实例管理 实例Instance是一个消息队列服务RabbitMQ实例,通过实例管理API提供的接口可以进行的操作有: 创建实例、查询指定实例详情、查询实例列表、修改实例信息、重置实例密码、删除指定实例、批量删除实例、 重启实例、添加白名单、删除白名单、查询白名单、申请公网访问连接地址、释放公网访问连接地址、获取实例证书包 API服务域名 百度智能云消息队列服务RabbitMQ的服务域名参见下表
切换生产者写入地址: 将生产客户端的Kafka连接地址修改为专享版 消息服务 for Kafka集群所提供的接入点地址。接入点查看请参考: 查看集群接入点 重启生产业务,使得生产者将新的消息发送到专享版 消息服务 for Kafka集群中。 观察各消费组在原Kafka的消费进度,直到原Kafka中数据都已经被消费完毕。
说明:勾选自定义关键词复选框,输入添加关键词,最多可以设置10个关键词,消息中至少包含其中1个关键词才可以发送成功。例如添加了一个自定义关键词:报警,则这个机器人所发送的消息,必须包含报警这个词,才能发送成功。 3.群内添加钉钉机器人,复制webhook地址,参考以上操作步骤填写到“报警回调”中即可。 4.配置成功后,当报警通知被触发时,您可以在钉钉群收到报警通知。