java -cp $CP Send 最后运行1-HelloWorld中的Recv类,从队列读取消息,按Ctrl+c退出 java -cp $CP Recv 具体过程如下图所示: 参考 https://github.com/rabbitmq/rabbitmq-tutorials/tree/master/java
查询用户列表 该接口用于查询集群的用户列表信息。 使用该接口时集群需要开启SASL身份认证。 请求结构 GET / v { version } / clusters / { clusterId } / users HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域
查询操作详情 该接口用于查询集群中任务某个操作的详细信息。 请求结构 GET / v { version } / clusters / { clusterId } / jobs / { jobId } / operations / { operationId } HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization :
查询任务详情 该接口用于查询集群中任务的详细信息。 请求结构 GET / v { version } / clusters / { clusterId } / jobs / { jobId } HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外,无其
查询任务列表 该接口用于查询集群中的任务列表。 请求结构 GET / v { version } / clusters / { clusterId } / jobs HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外,无其他特殊头域。 请求参数 参数
查询消费组列表 该接口用于查询集群中的消费组列表信息。 请求结构 GET / v { version } / clusters / { clusterId } / consumer - groups HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外
查询主题详情 该接口用于查询集群中指定主题(topic)的详细信息。 请求结构 GET / v { version } / clusters / { clusterId } / topics / { topicName } HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string
查询集群列表 该接口用于查询用户在该区域中所有使用中的集群列表信息。 请求结构 GET / v { version } / clusters HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外,无其他特殊头域。 请求参数 参数名称 类型 是否必须 参
查询权限列表 该接口用于查询集群的权限列表。 使用该接口时集群需要开启权限管理。 请求结构 GET / v { version } / clusters / { clusterId } / acls HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外
查询集群详情 该接口用于查询指定集群的详细信息。 请求结构 GET / v { version } / clusters / { clusterId } HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外,无其他特殊头域。 请求参数 参数名称 类型