检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Boolean true：开启指定的接入方式。 false：关闭指定的接入方式。 user_name 否 String 首次开启SASL时，需要输入用户名。实例创建后，关闭SASL并不会删除已经创建的用户，再次开启SASL时无需传入用户名，传入的用户名将无效。 pass_word
本文介绍Maven方式引入Kafka客户端，并完成Kafka实例连接以及消息生产与消费的相关示例。如果您需要在IDE中查看Demo具体表现，请查看Java开发环境搭建。 下文所有Kafka的配置信息，如实例连接地址、Topic名称、用户信息等，请参考收集连接信息获取。 Maven中引入Kafka客户端
Kafka实例的SASL_SSL开关如何修改？ 集群实例的SASL_SSL开关支持修改，具体步骤请参考修改实例的接入方式。 单机实例不支持SASL_SSL功能。 开启IPv6的实例不支持动态修改SASL_SSL开关。 父主题： 实例问题
STABLE：消费组内成员可以正常消费。 弹出“删除消费组”对话框，单击“确定”，完成消费组的删除。 使用命令行工具删除消费组 以下操作命令以Linux系统为例进行说明： 未开启密文接入的Kafka实例，在Kafka客户端的“/bin”目录下，通过以下命令删除消费组。 ./kafka-consumer-groups
约束与限制 首次修改接入方式时，部分实例会重启，另一部分实例不会重启，具体以控制台提示为准。实例重启大约需要75~80s。后续再次修改接入方式时，实例不会再重启。 单机实例只支持开启/关闭公网访问的明文接入。 开启了IPv6功能后，不支持修改实例的接入方式。 前提条件 只有处于“运行中”
是否支持跨Region访问？ Kafka可以跨Region访问，但是跨Region目前只能通过公网访问或者拉专线的方式。 父主题： 连接问题
老化时间即消息的最长保留时间，消费者必须在此时间结束前消费消息，否则消息将被删除。已删除的消息，无法被消费。 Topic老化时间默认为72小时，创建Topic成功之后，您可以根据业务需要修改Topic的老化时间。修改老化时间，不会影响业务。 修改老化时间可以通过以下方式实现： 在“Topic管理”中，修改老化时间。
Kafka实例是否支持修改访问端口？ Kafka实例的访问端口固定，不支持修改。 如果是访问未开启SASL的Kafka实例 支持的访问方式如下：同一VPC内访问、公网访问、跨VPC访问和DNAT访问。 同一VPC内使用IPv4地址访问，访问端口为9092。 同一VPC内使用IPv6地址访问，访问端口为9192。
Key)：与访问密钥ID结合使用的密钥，对请求进行加密签名，可标识发送方，并防止请求被修改。 使用AK/SK认证时，您可以基于签名算法使用AK/SK对请求进行签名，也可以使用专门的签名SDK对请求进行签名。详细的签名方法和SDK使用方法请参见API签名指南。 签名SDK只提供签名功能，与服务提供的SDK不同，使用时请注意。
区域：与Kafka实例保持一致。 名称：您自定义的公网NAT网关名称。 虚拟私有云：选择获取Kafka实例的信息中记录的虚拟私有云。 子网：选择获取Kafka实例的信息中记录的子网。 企业项目：根据实际情况选择。 其他参数请根据实际情况填写，如果想要了解更多的参数信息，请参考购买公网NAT网关。
Kafka使用场景 与RabbitMQ、RocketMQ的差异 产品规格 03 入门 创建Kafka实例之后，您可以通过命令行模式和客户端方式连接实例进行生产消息和消费消息。 命令行模式连接 连接未开启SASL的实例 连接已开启SASL的实例 客户端方式连接 Java客户端 Python客户端 Go客户端
Kafka监控显示消息堆积数跟实例里的消息数不一致？ 问题现象：监控显示消息堆积数为8.1亿+，Kafka控制台显示实例中6个Topic的消息数总和为1亿+，两者不一致。 问题结论：两者统计方式不同，Kafka控制台显示的消息数为实例中未消费的消息个数，而监控显示的消息堆积数=Topic中的消息积压数*消费组数。
Kafka支持SASL客户端认证、调用接口支持Token和AK/SK两种认证，Kerberos认证目前不支持。 如果使用SASL认证方式，则在开源客户端基础上使用分布式消息服务Kafka版提供的证书文件。具体操作参考使用客户端连接Kafka（开启SASL）。 父主题： 连接问题
本章节指导您删除Topic，请根据实际情况选择以下任意一种方式： 删除Kafka Topic（控制台） 删除Kafka Topic（Kafka客户端） 约束与限制 删除Topic会导致Topic中的数据也被删除，并且无法找回，同时会影响使用该Topic的相关业务。 已开启密文接入的实例，“allow.everyone
创建实例时可以手动指定实例节点的内网IP地址，仅支持指定IPv4地址。 指定内网IP地址数量必须小于等于购买的节点数量。 如果指定的内网IP地址数量小于购买的节点数量时，系统会自动为剩余的节点随机分配内网IP地址。 publicip_id 否 String 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。
选择需要诊断的消费组名称和Topic名称，单击“诊断前检查”。 诊断前检查成功后，如果“消息积压情况”显示有消息积压，并且消费组正在以非assign方式消费消息中，单击“开始诊断”。 诊断成功后，在诊断记录所在行，单击“查看详情”，进入“诊断详情”页面，查看导致消息堆积的可能原因、
扩容/缩容过程中生产消息失败 可能原因：在扩容/缩容代理规格的过程中，代理采用滚动重启的方式进行实例变更。在重启过程中，分区Leader会进行切换，此时生产客户端的元数据缓存中保存的分区Leader为旧分区Leader ID，仍然会向旧分区Leader发送消息，导致生产消息失败。
获取项目ID 操作场景 在调用接口的时候，部分URL中需要填入项目ID，所以需要获取到项目ID。有如下两种获取方式： 调用API获取项目ID 从控制台获取项目ID 调用API获取项目ID 项目ID可以通过调用查询指定条件下的项目信息API获取。 获取项目ID的接口为“GET https:
方法1：登录虚拟私有云服务的控制台界面，在虚拟私有云的详情页面查找VPC ID。 方法2：通过虚拟私有云服务的API接口查询，具体操作可参考查询VPC列表。 security_group_id String 是 指定实例所属的安全组。 获取方法如下： 方法1：登录虚拟私有云服务的控制台界面，在安全组的详情页面查找安全组ID。
Manager如何修改Topic的分区Leader？ 在Kafka Manager中修改Topic的分区Leader的步骤如下： 登录Kafka Manager。 选择“Topic > List”，进入Topic列表页面。 单击待修改分区Leader的Topic名称（以topic-test为例介绍），进入Topic详情页面。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
