概述与网络环境准备

本文概述

ROMA MQS完全兼容开源Kafka协议，可以直接使用kafka开源客户端连接。如果使用SASL认证方式，则在开源客户端基础上使用云服务提供的证书文件。

本指南主要介绍MQS连接信息的收集，如获取MQS连接地址与端口、SASL连接使用的证书、公网访问信息等，然后提供Java、Python等语言的连接示例。

本指南的示例仅展示Kafka的API调用，生产与消费的API集，请参考Kafka官网。

客户端网络环境说明

客户端有3种方式访问MQS：

• VPC内子网地址访问

  如果客户端是云上ECS，与MQS处于同region同VPC，则可以直接访问MQS提供的VPC内子网地址。

• VPC对等连接方式访问

  如果客户端是云上ECS，与MQS处于相同region但不同VPC，则可以通过建立VPC对等连接后，访问MQS提供的VPC内子网地址。

• 公网访问

  客户端在其他网络环境，或者与ROMA MQS处于不同region，则访问实例的公网地址。

  公网访问时，需要修改ROMA Connect实例绑定的安全组，增加入方向规则，允许端口9094、9095、9096被外部网络访问。

不同网络环境，对于客户端配置来说，只是连接地址的差异，其他都一样。因此，本手册以同一VPC内子网地址的方式，介绍客户端开发环境搭建。

遇到连接超时或失败时，请注意确认网络是否连通。可使用telnet方式，检测实例连接地址与端口。