CKafka系列学习文章 - 创建一个CKafka实例(三)

2019-11-12 10:46:13 浏览数 (1)

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

第 1 步:登录控制台

登录腾讯云控制台。

第 2 步:创建 CKafka 实例

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

例类型,创建实例。

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

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

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

第 3 步:创建topic

在右边的topic管理创建topic:

这里需要注意一下,购买的CKafka是Topic(主题)上限是25个,Partition(分区)上限是60个这里需要注意一下,购买的CKafka是Topic(主题)上限是25个,Partition(分区)上限是60个
比如我这里已经创建了两个topic,那还可以创建23个topic,但分区数已经用掉了3*3=9和3*2=6,15个,只有45个分区可以用了。比如我这里已经创建了两个topic,那还可以创建23个topic,但分区数已经用掉了3*3=9和3*2=6,15个,只有45个分区可以用了。

再创建topic时就会显示:

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

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

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

第一步:这里的网络类型要对应CKafka所选的网络型一样,不一样的话,需要在创建好的CKafka的实例中添加路由策略:看下面第一步:这里的网络类型要对应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配置好了JDK配置好了

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

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

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

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

kafka_2.10-0.10.2.0kafka_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管理界面的配置和参数设置

0 人点赞