注意,当前百度消息服务的数据存储时间默认为24小时,过期后自动删除,若有特殊需求,请提工单联系我们。 创建消费组 消费组是Kafka提供的可扩展且具有容错性的消费者机制。通过console创建的消费组享有完善的安全保护机制,强烈推荐用户采用这种方式使用消费者组功能。 注册并登录百度智能云平台,具体操作请参考注册和登录。 登录成功后,选择“产品服务>百度消息服务”,点击“消费组管理”后进入列表页。
消息查询 操作场景 用于在控制台中根据时间或者位点来查询主题中的消息。 注意事项 支持查询结果最多显示20条消息,且总大小不超过10MB。 每10秒可查询一次。 操作步骤 登录 消息服务 for Kafka控制台 进入集群列表页面,点击需要操作的集群。 在 消息查询 页面选择所要查询的主题、查询方式、分区、起始位点/时间等信息进行查询,并且点击右上角的下载按钮可以将本次查询到的消息下载到本地。
监控报警 查看监控 进入“产品服务>百度消息服务>主题”,点击要查看的主题名称,在详情页面中可看到监控数据图。 主题监控 可以查看该topic每秒读写的数据量(单位字节/秒),以及写入的消息个数(单位个/秒) 消费监控 在监控页面的右上角“消费组”处选择消费当前topic的消费组,若列表中没有所有查看的消费组,可通过输入消费组ID进行搜索查看。
java -cp $CP Send 最后运行1-HelloWorld中的Recv类,从队列读取消息,按Ctrl+c退出 java -cp $CP Recv 具体过程如下图所示: 参考 https://github.com/rabbitmq/rabbitmq-tutorials/tree/master/java
String 请求提交状态描述 data List SendMessageItem数组,一个SendMessageItem对应一个手机号的响应结果 SendMessageItem定义 参数名称 类型 描述 mobile String 手机号 code String 对应手机号的提交状态,1000表示成功 message String 对应手机号的响应结果描述 messageId String 对应手机号的消息
ID错误 建议联系平台核查原因 移动 M:00121 短消息超过有效期 建议联系平台核查原因 移动 M:00122 短消息的目的地址错误 建议联系平台核查原因 移动 M:00123 短消息的源地址错误 建议联系平台核查原因 移动 M:00124 短消息队列已满 建议联系平台核查原因 移动 M:00125 短消息内容超过了接收侧的最大长度 建议联系平台核查原因 移动 M:00126 短消息中指定的定时时间无效
KAFKA)变更集群、创建删除主题、主题重分区、创建删除访问控制列表、删除消费组、创建删除用户、读权限等 KAFKAReadOnlyAccessPolicy 只读专享版百度消息服务(KAFKA)权限 支持专享版百度消息服务(KAFKA)查看集群列表、查看集群详情、查看主题列表、查看主题详情、查看主题分区、查看消费组列表等 自定义策略 自定义策略允许用户根据自己的需求灵活配置自己的权限策略,对选定的资源生效
input.yml 步骤五:查看集群监控 查看消息是否发送成功或消费成功有两种方式: 在服务器端查看jar包运行日志。 在专享版消息服务 for Kafka控制台查看集群监控,获取集群生产、消息情况。 推荐使用第二种方式,下面介绍如何查看集群监控。 (1)在专享版消息服务 for Kafka的控制台页面找到需要连接的集群,点击集群名称进入 集群详情 页面。
topicName String 消费者实例所订阅的topic名称 consumerId String 正在消费当前分区的消费者实例ID,如果显示“-”则说明当前分区此时没有被消费者消费 clientId String 正在消费当前分区的客户端ID host String 正在消费当前分区的客户端IP maxOffset long 当前分区的最大位点 committedOffset long 当前消费者实例的消费位点
logstash - f input . conf 查看集群监控 查看消息是否发送成功或消费成功有两种方式: 在服务器端查看jar包运行日志。