-
Kafka实例是否支持修改访问端口? - 分布式消息服务Kafka版
Kafka实例是否支持修改访问端口? Kafka实例的访问端口固定,不支持修改。 如果是访问未开启SASL的Kafka实例 支持的访问方式如下:同一VPC内访问、公网访问、跨VPC访问和DNAT访问。 同一VPC内访问,访问端口为9092。 公网访问,访问端口为9094。 使用VPCEP跨VPC访问,访问端口为9011。
-
如何修改安全协议? - 分布式消息服务Kafka版
如何修改安全协议? 仅部分Region支持修改安全协议,具体以控制台为准。先在Kafka实例的详情页的“连接信息”区域,关闭密文接入,然后再开启密文接入,此时可以重新设置安全协议。 父主题: 实例问题
-
Kafka Manager WebUI的端口能否修改? - 分布式消息服务Kafka版
Kafka Manager WebUI的端口能否修改? Kafka Manager WebUI的端口不支持修改。 父主题: Kafka Manager问题
-
收集连接信息 - 分布式消息服务Kafka版
图4 开启的SASL认证机制 Kafka安全机制在Kafka实例控制台的基本信息页面中获取。如果页面未显示“启用的安全协议”,默认使用SASL_SSL协议。
-
选择和配置安全组 - 分布式消息服务Kafka版
fka实例。 表2 安全组规则 方向 策略 协议端口 目的地址 出方向 允许 全部 Default_All 图1 配置客户端安全组 Kafka实例所在安全组需要增加如下规则,以保证能被客户端访问。 表3 安全组规则 方向 策略 协议端口 源地址 入方向 允许 全部 sg-53d4
-
概述 - 分布式消息服务Kafka版
如果客户端在其他网络环境,或者与Kafka实例处于不同region,则访问实例的公网地址。 公网访问时,注意修改Kafka实例的安全组,允许端口9094(未开启SASL)/9095(开启SASL)被外部网络访问。 不同网络环境,对于客户端配置来说,只是连接地址的差异,其他都一样。因
-
连接Kafka网络要求 - 分布式消息服务Kafka版
通信”规则和出方向“放通全部流量”规则,此时使用内网通过同一个VPC访问Kafka实例,无需添加表2的规则。 表2 安全组规则 方向 协议 端口 源地址 说明 入方向 TCP 9094 0.0.0.0/0 通过公网访问Kafka实例(关闭SSL加密)。 入方向 TCP 9092 0
-
使用DNAT实现公网访问Kafka - 分布式消息服务Kafka版
使用场景:选择“虚拟私有云” 端口类型:选择“具体端口” 支持协议:选择“TCP” 公网IP类型:选择“弹性公网IP”,在下拉框中选择已购买的弹性公网IP 公网端口:输入“9011” 实例类型:选择“自定义” 私网IP:输入获取Kafka实例的信息中记录的Kafka实例的一个内网连接地址 私网端口:输入“9011”
-
配置Kafka实例的公网访问 - 分布式消息服务Kafka版
您可以在实例的“后台任务管理”页面,查看当前任务的操作进度。任务状态为“成功”,表示操作成功。 关闭公网访问后,需要设置对应的安全组规则,才能通过内网成功连接Kafka。连接Kafka的具体操作请参考连接实例。 表2 安全组规则(内网访问) 方向 协议 端口 源地址 说明 入方向 TCP
-
查询Kafka实例所有消费组对应的协调器信息 - 分布式消息服务Kafka版
所有消费组对应的协调器列表。参数参见表3。 表3 coordinators参数说明 参数 类型 说明 group_id String 消费组ID。 id Integer 对应协调器的broker id。 host String 对应协调器的地址。 port Integer 端口号。 响应示例
-
Python - 分布式消息服务Kafka版
制”,默认使用PLAIN机制。 security_protocol:Kafka的安全协议。在Kafka实例控制台的基本信息页面中获取。如果页面未显示“启用的安全协议”,默认使用SASL_SSL协议。 非SASL认证方式 from kafka import KafkaProducer
-
实例问题 - 分布式消息服务Kafka版
创建的Kafka实例是集群模式么? Kafka实例是否支持修改访问端口? Kafka实例的SSL证书有效期多长? 如何将Kafka实例中的数据同步到另一个Kafka实例中? Kafka实例的SASL_SSL开关如何修改? SASL认证机制如何修改? 如何修改安全协议? 修改企业项目,是否会导致Kafka重启?
-
快速连接Kafka并生产消费消息 - 分布式消息服务Kafka版
的操作步骤,请参考创建安全组。 连接Kafka实例前,请添加表1所示安全组规则,其他规则请根据实际需要添加。 表1 安全组规则 方向 协议 端口 源地址 说明 入方向 TCP 9093 0.0.0.0/0 使用内网通过同一个VPC访问Kafka实例(密文接入)。 安全组创建后,系
-
Go - 分布式消息服务Kafka版
码。 caFile:证书文件。 security.protocol:Kafka的安全协议。在Kafka实例控制台的基本信息页面中获取。如果页面未显示“启用的安全协议”,默认使用SASL_SSL协议。 sasl.mechanism:SASL认证机制。在Kafka实例控制台的基本信息
-
Java客户端接入示例 - 分布式消息服务Kafka版
username="username" \ password="password"; #设置Kafka安全协议。security.protocol为安全协议。 #安全协议为“SASL_SSL”时,配置信息如下。 security.protocol=SASL_SSL #ssl truststore
-
构造请求 - 分布式消息服务Kafka版
公共请求消息头 名称 描述 是否必选 示例 Host 请求的服务器信息,从服务API的URL中获取。值为hostname[:port]。端口缺省时使用默认的端口,https的默认端口为443。 否 使用AK/SK认证时该字段必选。 code.test.com or code.test.com:443
-
查看和修改Kafka实例基本信息 - 分布式消息服务Kafka版
Kafka SASL_SSL 是否开启SASL_SSL开关。 单机版实例不支持开启SASL_SSL。 启用的安全协议 开启SASL_SSL后,实例已启用的安全协议。 开启的SASL认证机制 开启SASL_SSL后,实例已开启的SASL认证机制。 SSL证书 单击“下载”,下载连接实例的SSL证书。
-
spring-kafka的使用 - 分布式消息服务Kafka版
username="username" \ password="password"; ## 设置Kafka安全协议。spring.kafka.security.protocol为安全协议。 ## 安全协议为“SASL_SSL”时,配置信息如下。 spring.kafka.security.protocol=SASL_SSL
-
查询可用区信息 - 分布式消息服务Kafka版
是否售罄。 id String 可用区ID。 code String 可用区编码。 name String 可用区名称。 port String 可用区端口号。 resource_availability String 分区上是否还有可用资源。 true:还有资源。 false:资源已售罄。
-
Java开发环境搭建 - 分布式消息服务Kafka版
username="username" \ password="password"; #设置Kafka安全协议。security.protocol为安全协议。 #安全协议为“SASL_SSL”时,配置信息如下。 security.protocol=SASL_SSL #ssl truststore