本文将为您介绍分布式消息服务Kafka入门的基本流程,主要包括控制台创建Kafka专享版实例、使用弹性云主机连接实例的操作,帮助您快速上手Kafka。
您还可以通过API方式创建Kafka实例、在业务代码中连接Kafka实例。
操作流程
图Kafka使用流程
Kafka实例运行于虚拟私有云中,在创建实例前需要确保有可用的虚拟私有云。
Kafka实例创建后,您需要在弹性云主机中下载和安装Kafka开源客户端,然后才能进行生产消息和消费消息。
在创建实例时,您可以选择是否开启SASL访问,开启后,数据加密传输,安全性更高。同时,SASL开关只能在创建实例时设置,实例创建成功后,不支持修改。
- (可选)创建Topic
Kafka实例创建成功后,如果没有开启“Kafka自动创建Topic”,需要手动创建Topic,然后才能进行生产消息和消费消息。
- 连接实例
针对实例是否开启SASL开关,在连接时是否需要下载证书,区分以下两种场景:
配置Kafka实例监控告警策略,监控实际业务运行状态。
说明关于Kafka的相关概念,请参考Kafka基本概念。