CKafka系列学习文章 - 创建一个CKafka实例（三）

导语：前面我们介绍了消息队列也比较了各种消息队列，接下来创建一个CKafka来测试一下。

第 1 步：登录控制台

登录腾讯云控制台。

第 2 步：创建 CKafka 实例

进入 消息队列 CKafka 界面，点击新建按钮，填写相关配置并选择实

例类型，创建实例。

注：峰值带宽分别指入出带宽，峰值带宽40MB/s指出和入带宽峰值为40MB/s,但考虑实例的副本个数，需要均分。例如：客户要求40MB吞吐，3副本，则需要购买120MB/s的峰值带宽 。

创建成功

创建成功后，点击上图的ID/名称中的ID，进入实例的基本信息页面：

后期调用CKafka时会用到接入方式。自动创建是你用生产者客户端调用一个没有创建的topic时，会自动创建。

第 3 步：创建topic

在右边的topic管理创建topic：

这里需要注意一下，购买的CKafka是Topic（主题）上限是25个，Partition（分区）上限是60个

比如我这里已经创建了两个topic，那还可以创建23个topic，但分区数已经用掉了3*3=9和3*2=6，15个，只有45个分区可以用了。

再创建topic时就会显示：

最好提前规划好，如果后期遇到问题请提交工单。

可以修改topic的最大消息的大小限制，范围0B到8MB。

第 4 步：创建一台云服务器，并安装JDK环境

第一步：这里的网络类型要对应CKafka所选的网络型一样，不一样的话，需要在创建好的CKafka的实例中添加路由策略：看下面

第二步：创建安全组或选择安全组时要根据自己公司的情况配置

下载JDK

https://www.oracle.com/technetwork/java/javase/downloads/java-archive-downloads-javase7-521261.html

注册个账号并下载JDK，上传云主机上：

登入主机

移动到固定文件夹并解压缩

mkdir /usr/local/jdk mv jdk-7u79-linux-x64.tar.gz /usr/local/jdk/ cd /usr/local/jdk/ tar -xzvf jdk-7u79-linux-x64.tar.gz

配置环境变量 vim /etc/profile 在文件末尾加入如下环境变量的配置： export JAVA_HOME=/usr/local/jdk/jdk1.7.0_79 export JRE_HOME=/usr/local/jdk/jdk1.7.0_79/jre export PATH=$JAVA_HOME/bin:$JAVA_HOME/jre/bin:$PATH export CLASSPATH=.:$JAVA_HOME/lib/tools.jar:$JAVA_HOME/lib/dt.jar:$JRE_HOME/lib

JDK配置好了

第 5 步：下载 Kafka 工具包并上传到云主机中

记得这个是源码包，需要编译，下面的下载可直接使用。

下载地址：http://kafka.apache.org/downloads

这里面的下载后解压直接可用

kafka_2.10-0.10.2.0

第 6步：创建用户并配置ACL策略，实现公网用户认证，生产和消费

配置生产和消费者的配置文件:

cat /opt/kafka_2.10-0.10.2.0/config/producer.properties

行尾添加上面三行，注释其它配置

cat /opt/kafka_2.10-0.10.2.0/config/server.properties

行尾添加上面三行，注释其它配置

sasl.mechanism=PLAIN ###用户客户端连接的SASL机制

security.protocol=SASL_PLAINTEXT ###用于与CKafka代理节点进行通信的协议

sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username=“实例ID

#username” password=“password”; ###设置实例ID#用户名和密码

第 7步：测试使用用户认证生产消费消息

生产消息：cd /opt/kafka/bin & ./kafka-console-producer.sh --broker-list 123.206.249.190:9092 --topic face-car --producer.config ../config/producer.properties

生产成功

消费消息:cd /opt/kafka/bin & ./kafka-console-consumer.sh --bootstrap-server 123.222.222.190:9092 --new-consumer --topic face-car --consumer.config ../config/consumer.properties

消费成功

下一章将去看看消息队列CKafka管理界面的配置和参数设置