实现对接ROMA Connect的MQS，参数说明请参见表1。 图1 编辑Kafka 表1 对接MQS参数说明 参数 说明 Kafka集群地址 配置为ROMA Connect MQS的地址，多个之间用“,”分隔。ROMA Connect MQS的地址可在ROMA Connect控制台的“实例信息

查看更多 →

DefaultMQPushConsumer rocketMQConsumer = createRocketMQConsumer(); MqsProducer mqsProducer = new MqsProducer(); MessageListenerConcurrently

查看更多 →

华为云服务 函数工作流 短信服务 消息通知 对象存储服务 数据安全中心 图像识别 文字识别 人脸识别 CodeArts Artifact CodeArts Build CodeArts Check CodeArts Deploy CodeArts Req CodeArts Pipeline

查看更多 →

华为云服务 函数工作流 短信服务 消息通知 CodeArts Artifact CodeArts Build CodeArts Check CodeArts Deploy CodeArts Req CodeArts Pipeline CodeArts Repo CodeArts TestPlan

查看更多 →

出差申请 预订机票 退改机票 预订酒店 变更酒店 出行用车 预订火车票 退改火车票 视频讲解>管理员篇 差旅管控 通讯录 受益管理 审批管理 数据服务

查看更多 →

None 从申请、预订到报销，一站式了解差旅应用 出差申请 预订机票 退改机票 预订酒店 变更酒店 出行用车 预订火车票 退改火车票

查看更多 →

None 1分钟快速了解华为云慧通差旅产品能力 灵活审，高效批！差旅效率一路狂飙 订得更省心，采得更放心 洞悉有深度，管理识全局

查看更多 →

None 后台功能解读，带你轻松玩转华为云慧通差旅管理 差旅管控 通讯录 受益管理 审批管理 数据服务 订单管理 运营管理 预算管理

查看更多 →

消息集成 向Topic生产的消息是否有长度限制？ MQS支持的Kafka服务端版本是多少？

查看更多 →

场景说明 ROMA Connect的消息集成MQS完全兼容开源Kafka协议，业务应用需要开发并集成开源Kafka客户端或ROMA Connect提供的RESTful API，实现与MQS的消息连接。 集成开源客户端：业务应用直接集成开源Kafka客户端，并通过客户端连接MQS，实现消息的生产和消费。

查看更多 →

0/0 通过公网访问MQS（有SASL认证）。 入方向 TCP 9292 0.0.0.0/0 通过公网访问MQS（RESTful API方式）。 入方向 TCP 15003 0.0.0.0/0 通过公网访问ABM（RESTful API方式）。 父主题： 创建ROMA Connect实例

查看更多 →

mqs_sasl_ssl Boolean 否 转发的目的端MQS是否开启SSL，这里需要确认MQS是否启用了SSL。 user_name string 否 MQS启用SSL时，需要传入MQS的用户名，未启用SSL不需要传入该参数。 password string 否 MQS启用

查看更多 →

台运营管理服务，解决“搭建平台易，运营平台难”的问题，有效支持企业客户持续稳健运营，达成差旅管理目标，实现商业成功。 系统集成 通过华为云数字化差旅管理平台开放的API能力，提供统一的接口规范。企业可以使用自己的IT系统或自有差旅应用访问差旅的资源和服务，供应商和服务商也可以快速

查看更多 →

Connect是一个全栈式的企业集成平台，源自华为数字化转型集成实践，聚焦应用和数据连接，适配多种企业常见的使用场景。 IoT平台将数据推送至ROMA Connect的MQS服务，应用服务器可基于MQS获取设备上报消息。 2019/07/05 IoT平台增强版更名为设备管理服务 除名称变更外，功能及收

查看更多 →

Connect消息轨迹是灰色的，可能是MQS服务地址配置错误或没有配置。 解决方法：检查iotgateway容器的“roma-server”参数是否配置。若没有配置，请配置该参数或联系运维添加正确的“roma-server”地址（端口为“9776”），确认网络正常以及MQS服务器正常，兼容客户端版本。

查看更多 →

目标数据源主题，destination_type值为0时，从MQS服务中获取已有Topic；destination_type值为1、2或3时， 从对应KAFKA类数据源中获取已有Topic。 最小长度：0 最大长度：64 server 否 String 目标端数据源服务，如下情况时server字段必填：d

查看更多 →

功能介绍 删除Topic。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI DELETE /v2/{project_id}/mqs/instances/{instance_id}/topics

查看更多 →

数据目的端配置 参数 配置说明 数据目的端 本配置样例中把数据转发到ROMA Connect的消息集成MQS，此处选择“ROMA MQS”。 连接地址 选择当前ROMA Connect实例的消息集成 MQS内网连接地址，您可以在ROMA Connect实例控制台的“实例信息”页面中查看得到。

查看更多 →

的账号发布资产。 用户登录华为云，访问ROMA Connect的官网页面，查看该账号下是否有集成应用资产。 如果没有，则资产发布者需要进入ROMA Connect控制台，以当前账号重新创建集成应用。 如果是API资产，用户选择左边菜单的“服务集成APIC > API管理”进行查看。

查看更多 →

Kafka到Mysql的实时任务时，MQS中的Topic下有数据，但是FDI任务没有采集到数据。 原因分析 数据源配置的不是本实例下的MQS地址，所以本实例下的MQS中虽然有消息，但是FDI任务采集不到数据。 解决方案 检查任务配置与数据源配置，修改数据源配置为正确的MQS地址。 父主题： 数据集成任务

查看更多 →

getSaslConfig(String servers, String groupId, String username, String password) 访问MQS提供的kafka（开启sasl_ssl）。 输入参数 servers：kafkaConfig中的bootstrap.servers信息 gro

查看更多 →