检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
客户端参数配置建议 Kafka客户端的配置参数很多，以下提供Producer和Consumer几个常用参数配置。 表1 Producer参数 参数 默认值 推荐值 说明 acks 1 高可靠：all 高吞吐：1 收到Server端确认信号个数，表示procuder需要收到多少个这
所使用的客户端证书。 非SASL认证方式 注意，加粗内容需要替换为实例自有信息。 from kafka import KafkaProducer conf = { 'bootstrap_servers': ["ip1:port1","ip2:port2","ip3:port3"]
查询客户端应用关联的应用配额 功能介绍 查看指定客户端应用关联的应用配额。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI GET /v2/{project_id}/
C#客户端使用说明 操作场景 本文介绍C#版本的Kafka客户端连接指导，包括Kafka客户端安装，以及生产、消费消息。 前提条件 已获取MQS连接信息，具体请参见开发准备。 已安装开发工具和C#开发语言环境，具体请参见开发准备。 引入Kafka客户端 MQS基于Kafka社区版本1
引入Kafka客户端 MQS基于Kafka社区版本1.1.0、2.7，您可以在ROMA Connect实例控制台的“实例信息”页面，在“MQS基本信息”下查看Kafka版本信息。Go开源客户端的版本使用请参见客户端版本使用建议。 执行以下命令，安装对应版本的Go Kafka客户端。 go
Java客户端使用说明 操作场景 本文介绍Java版本的Kafka客户端连接指导，并完成客户端连接以及消息生产与消费的相关示例。 前提条件 已获取MQS连接信息，具体请参见开发准备。 已安装开发工具和Java开发语言环境，具体请参见开发准备。 引入Kafka客户端 MQS基于Kafka社区版本1
为ElasticSearch数据设置索引生命周期策略。 创建生命周期策略 登录Kibana可视化界面。 访问地址：IP:Port 其中，IP为ELK所部署服务器的IP；Port为Kibana端口号，默认为5601，也可以在修改ELK配置时自定义端口号。如果网络中部署了防火墙，需提前配置防火墙的端口访问权限。
添加VPC通道后端服务器组 功能介绍 在服务集成中创建VPC通道后端服务器组，VPC通道后端实例可以选择是否关联后端实例服务器组，以便管理后端服务器节点。 若指定名称的后端服务器组已存在，则更新对应后端服务器组信息。若请求体中包含多个重复名称的后端服务器定义，则使用第一个定义。 调试
是 String VPC通道后端服务器组名称 member_group_remark 否 String VPC通道后端服务器组描述 member_group_weight 否 Integer VPC通道后端服务器组权重值。 当前服务器组存在服务器且此权重值存在时，自动使用此权重值分配权重。
填写错误。 请检查数据源IP与FDI是否在同一个VPC内，若不在请先创建对等连接。 如何创建VPC对等连接请参考VPC对等连接。 请检查数据源服务器端防火墙是否开放连接端口。 请检查数据源服务器端IP白名单限制是否添加FDI数据面IP。 请检查数据源IP是否为客户自有的数据中心或私有网，如果是请先建立VPN连接。
删除VPC通道后端服务器组 功能介绍 删除指定的VPC通道后端服务器组 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI DELETE /v2/{project_id}
获取MQS连接信息 获取连接地址与端口 在ROMA Connect实例控制台的“实例信息”页面，在“基本信息”页签查看MQS连接地址。 使用Kafka客户端内网连接MQS：在“连接地址”下查看消息集成 MQS内网连接地址。 使用Kafka客户端公网连接MQS：在“连接地址”下查看消息集成 MQS公网连接地址。
添加后端服务器地址。 单击“添加后端服务器地址”。 在页面中配置后端服务器信息。 表4 后端服务器配置 参数 说明 后端服务器地址 填写后端服务器的IP地址。 是否备用节点 开启后对应后端服务器为备用节点，仅当非备用节点全部故障时工作。 端口 填写后端服务器的访问端口号，端口为0时使用负载通道的端口。
member_group_name String VPC通道后端服务器组名称 member_group_remark String VPC通道后端服务器组描述 member_group_weight Integer VPC通道后端服务器组权重值。 当前服务器组存在服务器且此权重值存在时，自动使用此权重值分配权重。
批量修改后端服务器状态可用 功能介绍 批量修改后端服务器状态可用。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI POST /v2/{project_id}/api
(白名单类型) DENY (黑名单类型) app_acl_values 是 Array of strings ACL策略值，支持IP、IP范围和CIDR方式。IP范围以英文中划线分隔。 响应参数 状态码： 201 表4 响应Body参数 参数 参数类型 描述 app_id String
MQTT/MQTTS连接地址：在设备管理页面上方获取设备的接入地址，如果使用MQTT接入，则获取“MQTT连接地址”；如果使用MQTTS接入，则获取“MQTTS连接地址”，并下载SSL证书。 客户端ID/用户名/密码：在设备页签下找到对应的设备，并获取设备的“客户端ID”、“用户名”和“密码”。
查看指定APP的详细信息。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI GET /v2/{project_id}/apic/instances/{instance_id}/apps/{app_id}
附录：spring-kafka对接限制 概述 spring-kafka兼容开源Kafka客户端，其与开源Kafka客户端的版本对应关系可参见Spring官网。spring-kafka兼容的Kafka客户端版本主要为2.x.x版本，而ROMA Connect消息集成的Kafka服务端版本为1
应的API。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI DELETE /v2/{project_id}/apic/instances/{instance_id}
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
