专栏首页发哥说消息队列CKafka系列学习文章 - 创建一个CKafka实例(三)
原创

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管理界面的配置和参数设置

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

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

我来说两句

0 条评论
登录 后参与评论

相关文章

  • CKafka系列学习文章 - CKafka界面管理(四)

    导语:在使用的过程中,我们总是需要根据自己公司的业务场景去调整服务端的参数配置和监控参数,接下来我们一起来看看如何配置。

    发哥说消息队列
  • CKafka系列学习文章 - 搭建单机模式zookeeper+kafka(十四)

    导语:搭建单机模式的zookeeper+kafka,用来做开发测试环境,管理主题、分区、生产消费及主题数据的导入导出。

    发哥说消息队列
  • CKafka系列学习文章 - CKafka场景案例(五)

    导语:当我们的公司在不断发展时,业务也是遍布全国或者已经国际化了,公司内部的各种系统也是越来越多,还要对接其它公司的系统,来实现公司业务的正常运转。这时我们通常...

    发哥说消息队列
  • day66-Django进阶-Django路由系统介绍

    少年包青菜
  • 使用对象存储最低成本搭建静态网站

    域名,很简单,在腾讯云直接注册即可:https://cloud.tencent.com/act/cps/redirect?redirect=10025&cps_...

    Ar-Sr-Na
  • 腾讯云CDN使用(接入方式:COS源)

    当然推荐上传工具啦, 很好用 下载地址: https://cloud.tencent.com/document/product/436/11366

    治电小白菜
  • 【IOT迷你赛】智慧照明

    很荣幸参加这次的TencentTiny内测,切身体会了IOT的魅力认识到其市场价值,在月初收到腾讯工作人员寄来的开发板感觉特别的荣幸--能与腾讯近距...

    格创苗兴航
  • 小白建站教程-腾讯云建站

    一直想着有一天能够拥有自己的网站,以前只是知道网站需要服务器和域名,不知道怎么建站,自己瞎折腾这么久,多少也了解一下,现在把这个流程整理如下:

    云上云
  • angular2.0+ 模块之间共享service并订阅更新

    之前试过用“eventEmitter”想再值变动之后发射出去,但是在“ChildComponent”接受不到值的变化,通过查阅得知“eventEmitter”只...

    用户2436820
  • 微信小程序组件化开发框架wepy

    达达前端

扫码关注云+社区

领取腾讯云代金券