操作流程 获取MQS连接信息，具体请参考开发准备。 若ROMA Connect实例的消息集成在开启SASL_SSL的同时，也开启了VPC内网明文访问，则VPC内无法使用SASL方式连接消息集成的Topic。 使用SASL方式连接消息集成的Topic时，建议在客户端所在主机的“/etc/h

查看更多 →

基于Kafka的Word Count数据流统计案例 应用场景 Kafka是一个分布式的消息发布-订阅系统。它采用独特的设计提供了类似JMS的特性，主要用于处理活跃的流式数据。 Kafka有很多适用的场景：消息队列、行为跟踪、运维数据监控、日志收集、流处理、事件溯源、持久化日志等。

查看更多 →

分布式消息服务Kafka版 本章节介绍在创建事件流时，如何配置分布式消息服务Kafka版实例为事件源。 前提条件 已在分布式消息服务Kafka版中购买Kafka实例，详情请参见购买Kafka实例。 Kafka实例中的安全组在“入方向规则”中放开Kafka实例的子网网段和端口，详情

查看更多 →

dws-client 简介 dws-client是一款基于DWS JDBC实现的高性能、便捷入库工具，用户在使用时必须保证JDBC可以连接。其中使用dws-client入库具备如下优势： dws-client提供对缓存的空间、时间维度的限制，支持攒批提升入库性能，以满足业务在高峰低谷期的入库实时性。

查看更多 →

在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。 在左侧导航栏单击“Kafka实例”，进入Kafka实例列表页面。 单击Kafka实例的名称，进入实例详情页面。 在“连接信息 > SSL证书”后，单击“下载”，将SSL证书下载到本地。

查看更多 →

单击“新建连接”。 选择“Kafka”连接器。 在弹窗中配置连接器信息，完成后单击“确定”。 参数 说明 连接名称 填写连接器实例名称。 Brokers地址 填写Kafka的Brokers地址。 认证方式 选择Kafka的认证方式。 SSL认证 无认证 SASL鉴权方式 仅当“认证方式”选择“SSL认证”时需要配置。

查看更多 →

Kafka同步Kafka 当前仅支持华南-广州。 前提条件 业务有自己的源Kafka和目标Kafka。 源Kafka和目标Kafka实例支持的版本：目前支持2.7及以上，后续支持版本会持续更新。 源Kafka和目标Kafka实例的规格、存储空间需保持一致。 确保vpc、子网、kafka等资源充足。

查看更多 →

sight Manager，选择“集群 > 服务 > Kafka”，查看当前Kafka状态，发现状态为良好，且监控指标内容显示正确。 通过Kafka Client，判断是否可以正常消费数据。 假设客户端已经安装在/opt/client目录，test为需要消费的Topic名称， 192

查看更多 →

Flume正常连接Kafka后发送消息失败 问题现象 使用 MRS 版本安装集群，主要安装ZooKeeper、Flume、Kafka。 在使用Flume向Kafka发送数据功能时，发现Flume发送数据到Kafka失败。 可能原因 Kafka服务异常。 Flume连接Kafka地址错误，导致发送失败。

查看更多 →

/opt/client/Kafka/kafka/config/producer.properties 重新打开一个客户端连接窗口，执行以下命令，使用“kafka-console-consumer.sh”从输出Topic消费数据，查看统计结果。 cd /opt/client source

查看更多 →

使用内网通过同一个VPC访问Kafka实例的连接地址（内网连接地址） 图2 使用内网通过同一个VPC访问Kafka实例的连接地址（内网明文连接地址） 如果是公网访问，Kafka连接地址如下图所示。 图3 公网访问Kafka实例的连接地址（公网连接地址） 图4 公网访问Kafka实例的连接地址（公网明文连接地址）

查看更多 →

WebUI界面。 新建集群连接，如：flink_hive。 选择“系统管理 > 集群连接管理”，进入集群连接管理页面。 单击“创建集群连接”，在弹出的页面中参考表1填写信息，单击“测试”，测试连接成功后单击“确定”，完成集群连接创建。 表1 创建集群连接信息 参数名称 参数描述 取值样例

查看更多 →

sasl_kerberos_principal 连接Kafka的principal，输入1创建的用户名。 kafka.sasl_kerberos_realm 配置为Kafka集群的 域名 。 kafka.sasl_mechanisms 指定连接Kafka使用的SASL认证机制，参数值为GSSAPI。 kafka_auth_mode

查看更多 →

config /opt/client/Kafka/kafka/config/producer.properties 重新打开一个客户端连接窗口。 cd /opt/client source bigdata_env 执行命令消费Topic1中的消息。 kafka-console-consumer

查看更多 →

，参数值为PLAIN。 kafka.sasl_password 连接Kafka用户的密码，新建的用户ck_user1需要先修改初始密码，否则会导致认证失败。 kafka.sasl_username 连接Kafka的用户名，输入1创建的用户名。 kafka_auth_mode Cl

查看更多 →

连接SQL Server实例的方式 云数据库 RDS for SQL Server提供使用SQL Server Management Studio客户端和数据管理服务（Data Admin Service，简称DAS）的连接方式。 表1 RDS连接方式 连接方式 使用场景 通过DAS连接RDS

查看更多 →

Service，简称DAS）的连接方式。 命令行内网和公网连接实例 使用命令行连接RDS for MySQ L实例 ，支持内网和公网两种连接方式，如表1所示。 表1 内网和公网连接方式 连接方式 IP地址 安全组规则 说明 内网连接 内网IP地址 E CS 与RDS实例在相同安全组，默认ECS与RDS实例内网互通，无需设置安全组规则。

查看更多 →

连接数据库（以UDS方式） UNIX domain socket用于同一主机上不同进程间的数据交换，通过添加junixsocket获取套接字工厂使用。 需要引用的jar包有junixsocket-core-XXX.jar、junixsocket-common-XXX.jar、ju

查看更多 →

连接数据库（以SSL方式） 数据库的Go驱动支持SSL连接数据库，当开启SSL模式后，如果Go驱动采用SSL方式连接数据库服务端时，Go驱动默认走TLS 1.3标准协议，支持的tls版本最低为1.2。本小节主要介绍应用程序通过Go如何采用SSL的方式对客户端进行配置（服务端配置请

查看更多 →

JDBC通过ssl方式连接doris(验证证书) 在应用层进行代码重试和负载均衡时，代码重试需要应用自己多个配置doris前端节点地址。比如发现一个连接异常退出，就自动在其他连接上进行重试。 前提条件：集群必须开启HTTPS。 下载证书请在集群详情页面下载。 在已安装mysql客

查看更多 →

连接数据库（以SSL方式） 数据库的Go驱动支持SSL连接数据库，当开启SSL模式后，如果Go驱动采用SSL方式连接数据库服务端时，Go驱动默认走TLS 1.3标准协议，支持的tls版本最低为1.2。本小节主要介绍应用程序通过Go驱动如何采用SSL的方式对客户端进行配置（服务端配

查看更多 →