分布式消息服务Kafka版
分布式消息服务Kafka版
- 最新动态
- 功能总览
- 服务公告
- 产品介绍
- 计费说明
- 快速入门
- 用户指南
- 最佳实践
- 开发指南
- API参考
- SDK参考
-
常见问题
-
实例问题
- 为什么可用区不能选择2个？
- 创建实例时为什么无法查看子网和安全组等信息？
- 如何选择Kafka实例的存储空间？
- Kafka实例的超高IO和高IO如何选择？
- 如何选择Kafka实例存储容量阈值策略？
- Kafka服务端支持版本是多少？
- Kafka实例的ZK地址是什么？
- 创建的Kafka实例是集群模式么？
- Kafka实例是否支持修改访问端口？
- Kafka实例的SSL证书有效期多长？
- 如何将Kafka实例中的数据同步到另一个Kafka实例中？
- Kafka实例的SASL_SSL开关如何修改？
- SASL认证机制如何修改？
- 如何修改安全协议？
- 修改企业项目，是否会导致Kafka重启？
- 100MB/s的带宽怎样开启公网访问？
- Kafka服务和ZK是部署在相同的虚拟机中，还是分开部署？
- Kafka包周期实例支持删除吗？
- Kafka支持哪些加密套件？
- 购买实例时选择的单AZ，怎样可以扩展为多AZ？
- Kafka是否支持跨AZ容灾？已经购买的实例在哪里查看是否为跨AZ？
- Kafka支持磁盘加密吗？
- Kafka实例创建后，能修改VPC和子网吗？
- 有没有Kafka Stream的案例？
- Kafka实例版本可以升级吗？
- 怎样重新绑定公网IP？
- 实例规格变更问题
-
连接问题
- 选择和配置安全组
- Kafka实例是否支持公网访问？
- Kafka实例的连接地址默认有多少个？
- 是否支持跨Region访问？
- Kafka实例是否支持跨VPC访问？
- Kafka实例是否支持不同的子网？
- Kafka是否支持Kerberos认证，如何开启认证？
- Kafka实例是否支持无密码访问？
- 开启公网访问后，在哪查看公网IP地址？
- Kafka支持服务端认证客户端吗？
- 连接开启SASL_SSL的Kafka实例时，ssl truststore文件可以用PEM格式的吗？
- 下载的证书JKS和CRT有什么区别？
- Kafka支持哪个版本的TLS？
- Kafka实例连接数有限制吗？
- 客户端单IP连接的个数为多少？
- Kafka实例的内网连接地址可以修改吗？
- 不同实例中，使用的SSL证书是否一样？
- 为什么不建议使用Sarama客户端收发消息？
- Topic和分区问题
- 消费组问题
- 消息问题
-
Kafka Manager问题
- 登录Kafka Manager的账号是否可以设置为只读账号？
- 登录到Kafka Manager页面，为什么获取不到节点信息？
- Yikes! Insufficient partition balance when creating topic : projectman_project_enterprise_project Try again.
- Kafka Manager能否查询到消息的正文？
- Kafka Manager WebUI的端口能否修改？
- 在Kafka Manager上支持修改Topic的哪些属性？
- Kafka Manager和云监控显示的信息不一致
- Kafka Manager如何修改Topic的分区Leader？
- 实例版本在控制台和Kafka Manager上显示不一致？
- 为什么实例中存在默认名为__trace和__consumer_offsets的Topic？
- 客户端删除消费组后，在Kafka Manager中仍可以看到此消费组？
- 监控告警问题
- Kafka体验版使用说明
-
实例问题
- 故障排除
- 视频帮助
- 文档下载
- 通用参考
链接复制成功！
删除Kafka Topic
本章节指导您删除Topic，请根据实际情况选择以下任意一种方式：
约束与限制
- 删除Topic会导致Topic中的数据也被删除，并且无法找回，同时会影响使用该Topic的相关业务。
- 已开启密文接入的实例，“allow.everyone.if.no.acl.found”设置为“false”时，初始用户（即首次开启密文接入时设置的用户）可以通过客户端删除Topic，其他用户无法通过客户端删除Topic。
前提条件
只有运行中的实例才可以删除Topic。
删除Kafka Topic（控制台）
- 登录管理控制台。
- 在管理控制台左上角单击
，选择Kafka实例所在的区域。 - 在管理控制台左上角单击
，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。 - 在左侧导航栏单击“Kafka实例”，进入Kafka实例列表页面。
- 单击Kafka实例的名称，进入实例详情页面。
- 在左侧导航栏选择“Topic管理”，进入Topic列表页面。
- 通过以下任意一种方法，删除Topic。
- 勾选Topic名称左侧的方框，可选一个或多个，单击信息栏左上侧的“删除Topic”。
- 在待删除Topic所在行，单击“更多 > 删除”。
- 在“删除Topic”对话框中，单击“确定”，确认删除Topic。
删除Kafka Topic（Kafka客户端）
Kafka客户端版本为2.2以上时，支持通过kafka-topics.sh删除Topic。
- 未开启密文接入的Kafka实例，在Kafka客户端的“/bin”目录下，通过以下命令删除Topic。
./kafka-topics.sh --bootstrap-server ${connection-address} --delete --topic ${topic-name}参数说明如下：
- connection-address：在Kafka控制台的“基本信息 > 连接信息”中，获取Kafka实例的连接地址。
- topic-name：Topic名称。
示例如下：
[root@ecs-kafka bin]# ./kafka-topics.sh --bootstrap-server 192.168.xx.xx:9092,192.168.xx.xx:9092,192.168.xx.xx:9092 --delete --topic topic-01 [root@ecs-kafka bin]#
- 已开启密文接入的Kafka实例，通过以下步骤删除Topic。
- （可选）修改客户端配置文件。
在Kafka控制台的“基本信息 > 连接信息”中查看Kafka安全协议，两种安全协议对应的配置文件设置有所不同，请根据实际情况配置。
- SASL_PLAINTEXT：如果已经设置了用户名和密码，请跳过此步骤，执行2。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，在文件中增加如下内容。
security.protocol=SASL_PLAINTEXT #SASL认证机制为“SCRAM-SHA-512”时，配置信息如下。 sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required \ username="**********" \ password="**********"; sasl.mechanism=SCRAM-SHA-512 #SASL认证机制为“PLAIN”时，配置信息如下。 sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \ username="**********" \ password="**********"; sasl.mechanism=PLAIN
参数说明如下：username和password为首次开启密文接入时填入的用户名和密码，或者创建用户时设置的用户名和密码。
- SASL_SSL：如果已经设置了用户名和密码，以及SSL证书配置，请跳过此步骤，执行2。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，在文件中增加如下内容。
security.protocol=SASL_SSL ssl.truststore.location={ssl_truststore_path} ssl.truststore.password=dms@kafka ssl.endpoint.identification.algorithm= #SASL认证机制为“SCRAM-SHA-512”时，配置信息如下。 sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required \ username="**********" \ password="**********"; sasl.mechanism=SCRAM-SHA-512 #SASL认证机制为“PLAIN”时，配置信息如下。 sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \ username="**********" \ password="**********"; sasl.mechanism=PLAIN参数说明如下：
- ssl.truststore.location配置为client.jks证书的存放路径。注意，Windows系统下证书路径中也必须使用“/”，不能使用Windows系统中复制路径时的“\”，否则客户端获取证书失败。
- ssl.truststore.password为服务器证书密码，不可更改，需要保持为dms@kafka。
- ssl.endpoint.identification.algorithm为证书域名校验开关，为空则表示关闭。这里需要保持关闭状态，必须设置为空。
- username和password为首次开启密文接入时填入的用户名和密码，或者创建用户时设置的用户名和密码。
- SASL_PLAINTEXT：如果已经设置了用户名和密码，请跳过此步骤，执行2。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，在文件中增加如下内容。
- 在Kafka客户端的“/bin”目录下，通过以下命令删除Topic。
./kafka-topics.sh --bootstrap-server ${connection-address} --delete --topic ${topic-name} --command-config ../config/ssl-user-config.properties参数说明如下：
- connection-address：在Kafka控制台的“基本信息 > 连接信息”中，获取Kafka实例的连接地址。
- topic-name：Topic名称。
示例如下：
[root@ecs-kafka bin]# ./kafka-topics.sh --bootstrap-server 192.168.xx.xx:9093,192.168.xx.xx:9093,192.168.xx.xx:9093 --delete --topic topic-01 --command-config ../config/ssl-user-config.properties [root@ecs-kafka bin]#
- （可选）修改客户端配置文件。
父主题： Topic管理
