产品功能
本页面介绍了Kafka服务支持的主要功能。关于各功能支持的地域(Region)信息,可通过控制台查询详情。
购买Kafka实例
您在使用分布式消息服务Kafka版前,需要先购买Kafka实例。Kafka实例采用物理隔离的方式部署,租户独占Kafka实例。详情请参见购买Kafka实例。
连接Kafka
开源Kafka客户端向Kafka实例生产消息和消费消息前,需要先连接Kafka实例。
创建Kafka实例时,支持开启或者关闭SASL_SSL。开源Kafka客户端连接开启SASL_SSL的Kafka实例,与连接未开启SASL_SSL的Kafka实例的端口号不同,且开启SASL_SSL的Kafka实例需要配置证书信息。详情请参见连接实例。
Topic管理
Topic,即消息主题。创建Kafka实例后,如果没有开启“kafka自动创建Topic”,需要手动创建Topic,然后才能进行生产消息和消费消息。详情请参见创建Kafka Topic。
创建Topic后,您可以根据业务需要修改Topic的老化时间,详情请参见修改Kafka消息老化时间。
变更实例规格
Kafka实例创建成功后,您可以根据业务需要,扩容基准带宽、代理个数、存储空间、代理规格,或者缩容代理规格。详情请参见变更实例规格。
公网访问
您需要通过公网地址访问Kafka实例时,可开启实例的公网访问功能,并设置公网带宽。当开启成功后,您还可以根据需要修改公网带宽的大小,当前仅支持带宽扩容,不支持缩容。详情请参见配置Kafka实例的公网访问。
部分区域不支持“基准带宽”为“100MB/s”的Kafka实例开启公网访问,具体以控制台为准。
消息查询
您可以查看指定Topic的消息大小、创建时间以及消息正文。详情请参见查看Kafka消息。
Kafka Manager管理
Kafka Manager是开源的Kafka集群管理工具,您可以通过浏览器访问Kafka Manager。在Kafka Manager页面,您可以查看Kafka集群的监控、节点等信息。详情请参见管理Kafka Manager。
Smart Connect
分布式消息服务Kafka版通过开启Smart Connect,实现Kafka实例和其他云服务(如OBS)之间的数据同步,或者两个Kafka实例之间的数据同步。详情请参见开启Smart Connect。
用户管理
分布式消息服务Kafka版支持对Topic进行ACL权限管理,您可以在Topic中为不同的SASL_SSL用户设置不同的权限,以达到SASL_SSL用户之间的权限隔离。详情请参见配置Kafka ACL用户。
消费组管理
分布式消息服务Kafka版支持在控制台删除消费组、重置消费进度以及查看消费者连接地址。详情请参见管理消费组。
修改配置参数
分布式消息服务Kafka版为实例、Topic、消费者提供了几个常用配置参数的默认值,您可以根据实际业务需求,在控制台自行修改参数值。详情请参见修改Kafka实例配置参数。
标签
标签是Kafka实例的标识,为Kafka实例添加标签,可以方便用户识别和管理拥有的Kafka实例资源。
您可以在创建Kafka实例时添加标签,也可以在Kafka实例创建完成后,在实例的详情页添加标签。详情请参见配置Kafka实例标签。
监控
云监控对Kafka实例的运行状态进行日常监控,可以通过控制台直观的查看Kafka实例各项监控指标。详情请参见查看监控指标与配置告警。
审计
云审计服务(Cloud Trace Service,CTS),是华为云安全解决方案中专业的日志审计服务,您可以通过CTS对Kafka实例的操作记录进行收集、存储和查询,用于安全分析、合规审计、资源跟踪和问题定位等。详情请参见查看Kafka审计日志。
API
分布式消息服务Kafka版提供了REST(Representational State Transfer)风格API,支持您通过HTTP/HTTPS请求调用,实现创建、修改、删除实例等操作。详情请参见API概览。