前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >CKafka系列学习文章 - 创建一个CKafka实例(三)

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

原创
作者头像
发哥说消息队列
修改2019-11-12 10:46:13
1.2K0
修改2019-11-12 10:46:13
举报
文章被收录于专栏:发哥说消息队列

导语:前面我们介绍了消息队列也比较了各种消息队列,接下来创建一个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.0
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管理界面的配置和参数设置

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 第 1 步:登录控制台
  • 第 2 步:创建 CKafka 实例
  • 第 3 步:创建topic
  • 第 4 步:创建一台云服务器,并安装JDK环境
  • 第 5 步:下载 Kafka 工具包并上传到云主机中
  • 第 6步:创建用户并配置ACL策略,实现公网用户认证,生产和消费
  • 第 7步:测试使用用户认证生产消费消息
相关产品与服务
消息队列 CMQ 版
消息队列 CMQ 版(TDMQ for CMQ,简称 TDMQ CMQ 版)是一款分布式高可用的消息队列服务,它能够提供可靠的,基于消息的异步通信机制,能够将分布式部署的不同应用(或同一应用的不同组件)中的信息传递,存储在可靠有效的 CMQ 队列中,防止消息丢失。TDMQ CMQ 版支持多进程同时读写,收发互不干扰,无需各应用或组件始终处于运行状态。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档