检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
修改Kafka的接入方式 功能介绍 修改Kafka的内网或者公网接入方式。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/{engine}/instances/{instance_id}/plain-ssl-switch 表1 路径参数 参数
已准备一台Linux系统的服务器，并安装Java Development Kit 1.8.111或以上版本，配置JAVA_HOME与PATH环境变量。 实例已开启Kafka SASL_SSL。 步骤一：制作客户端验证服务端的证书 登录Linux系统的服务器，执行以下命令，生成server
性。 弹性云服务器（Elastic Cloud Server） 弹性云服务器是由CPU、内存、操作系统、云硬盘组成的基础的计算组件。Kafka实例运行在弹性云服务器上，一个代理对应一台弹性云服务器。 云硬盘（Elastic Volume Service） 云硬盘为云服务器提供块存
Kafka实例的SASL_SSL开关如何修改？ 集群实例的SASL_SSL开关支持修改，具体步骤请参考修改实例的接入方式。 单机实例不支持SASL_SSL功能。 开启IPv6的实例不支持动态修改SASL_SSL开关。 父主题： 实例问题
修改Kafka实例Topic分区的副本 功能介绍 修改Kafka实例Topic分区的副本。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/management/topics/{topic}/r
IP，或者域名。 说明： IP修改未修改项也需填上。 响应参数 状态码：200 表3 响应Body参数 参数 参数类型 描述 success Boolean 修改跨VPC访问结果。 results Array of results objects 修改broker跨VPC访问的结果列表。
修改用户/客户端流控配置 功能介绍 该接口用于向Kafka实例提交修改用户、客户端级别的流控任务，若成功则返回流控任务的job_id。 调用方法 请参见如何调用API。 URI PUT /v2/kafka/{project_id}/instances/{instance_id}/
修改自动创建Topic的配置，会触发重启吗？ 开启或者关闭“Kafka自动创建Topic”，会导致Kafka重启。 父主题： Topic和分区问题
据实际运行环境修改路径格式。 spring.kafka.ssl.trust-store-location=file:D:\\temp\\client.jks ## spring.kafka.ssl.trust-store-password为服务器证书密码，无需修改，配置此密码是为了访问Java生成的jks文件。
获取Kafka命令行工具2.7.2版本。 购买客户端服务器。 购买如下参数的2台ECS服务器，具体步骤请参考购买弹性云服务器。 区域、可用区、虚拟私有云、子网、安全组与Kafka实例保持一致，规格为4U8G，Linux系统的ECS。 区域、虚拟私有云、子网、安全组与Kafka实例保
前提条件 已准备一台Linux系统的服务器，并安装Java Development Kit 1.8.111或以上版本，配置JAVA_HOME与PATH环境变量。 实例已开启Kafka SASL_SSL。 步骤一：制作证书 登录Linux系统的服务器，执行以下命令，生成server.keystore
以直接访问Kafka实例提供的内网连接地址。 如果客户端是云上ECS，与Kafka实例处于相同region但不同VPC，通过以下任意一种方式访问。 创建VPC对等连接，将两个VPC的网络打通，实现跨VPC访问。具体步骤请参考对等连接。注意修改Kafka实例的安全组，允许端口909
ceTaskFailure 提交修改DMS实例信息请求成功 kafka modifyDMSInstanceInfoSuccess 修改DMS实例信息任务执行成功 kafka modifyDMSInstanceInfoTaskSuccess 提交修改DMS实例信息请求失败 kafka
--all-groups 参数说明如下：connection-address表示Kafka实例的连接地址，在Kafka控制台的“基本信息 > 连接信息”中获取。 示例如下： [root@ecs-kafka bin]# ./kafka-consumer-groups.sh --bootstrap-server
如果已开启公网访问，在“弹性IP地址”中，选择新扩容代理的公网IP地址。 “子网”保持默认设置。 在“内网IP地址”中，选择“自动分配”或者“手动选择”。 自动分配：系统自动分配子网中可用的IP地址。 手动选择：在下拉框中为新扩容代理勾选指定的IP地址。如果指定的IP地址数量少于代理数量时，系统会自动为剩余代理分配IP地址。
properties文件中的ssl.truststore.password参数是否配置正确。 ssl.truststore.password为服务器证书密码，不可更改，需要保持为dms@kafka ssl.truststore.password=dms@kafka Topic名称错误 出现下图的错误信息：
connection-address：在Kafka控制台的“基本信息 > 连接信息”中，获取Kafka实例的连接地址。 topic-name：Topic名称。 示例如下： [root@ecs-kafka bin]# ./kafka-topics.sh --bootstrap-server 192
${connection-address} --list 参数说明如下：connection-address表示Kafka实例的连接地址，在Kafka控制台的“基本信息 > 连接信息”中获取。 示例如下： [root@ecs-kafka bin]# ./kafka-consumer-groups.sh --bootstrap-server
Kafka Manager”后，单击，关闭Kafka Manager。 关闭Kafka Manager后，控制台不显示Kafka Manager连接地址，不支持重置Kafka Manager密码和重启Kafka Manager功能。 父主题： 管理Kafka Manager
indows系统路径格式举例，您在使用时请根据实际运行环境修改路径格式。 ssl.truststore.location=E:\\temp\\client.pem #ssl.truststore.password为服务器证书密码，使用PEM格式证书访问Kafka实例，无需配置ssl
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
