【华为云Kafka全景实践课】day1 Kafka入门基础知识实操记录

举报
JaneConan 发表于 2019/08/12 22:12:29 2019/08/12
【摘要】 最近也是在学习消息队列的知识,很有幸参加这次学习活动。废话不多说,直接入正题!从华为云源下载Kafkawget https://repo.huaweicloud.com/apache/kafka/1.1.0/kafka_2.12-1.1.0.tgz解压tar zxvf kafka_2.12-1.1.0.tgz访问华为云Kafka控制台https://console.huaweicloud.c...

最近也是在学习消息队列的知识,很有幸参加这次学习活动。

废话不多说,直接入正题!


从华为云源下载Kafka

wget https://repo.huaweicloud.com/apache/kafka/1.1.0/kafka_2.12-1.1.0.tgz


解压

tar zxvf kafka_2.12-1.1.0.tgz


访问华为云Kafka控制台

https://console.huaweicloud.com/dms/?region=cn-east-2&engine=kafka&locale=zh-cn#/queue/manager/newKafkaList




登录 ECS 执行生产脚本

执行命令:

bin/kafka-console-producer.sh --broker-list {你的kafka broker地址} --topic {生产消息的topic(之前创建的名称)}


我们会发现未安装Java


在/usr/目录下创建java目录


mkdir /usr/java
cd /usr/java


下载Java 32位 jdk
https://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html

并上传至华为云服务器

scp jdk-8u221-linux-i586.tar.gz root@{您的公网IP地址}:/usr/java



注意:

使用如下指令,查看Linux的位数

getconf LONG_BIT

手册上给出的是32位Ubuntu

Ubuntu 14.04 server 32bit


或者您重新切换操作系统的位数为64位

下载Java 64位 jdk
wget https://obs.cn-southwest-2.myhuaweicloud.com/devops-resource/jdk-8u211-linux-x64.tar.gz


解压 JDK

tar -zxvf jdk-8u221-linux-i586.tar.gz


设置环境变量

修改 /etc/profile

vim /etc/profile


在 profile 文件中添加如下内容并保存:


set java environment
JAVA_HOME=/usr/java/jdk1.8.0_221
JRE_HOME=/usr/java/jdk1.8.0_221
CLASS_PATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$JRE_HOME/lib
PATH=$PATH:$JAVA_HOME/bin:$JRE_HOME/bin
export JAVA_HOME JRE_HOME CLASS_PATH PATH


注意:其中 JAVA_HOME, JRE_HOME 请根据自己的实际安装路径及 JDK 版本配置。


让修改生效:

source /etc/profile


测试

java -version

显示 java 版本信息,则说明 JDK 安装成功:


root@ecs-s3-small-1-linux-20190812203839:/usr/java/jdk1.8.0_221/bin# java -version

java version "1.8.0_221"

Java(TM) SE Runtime Environment (build 1.8.0_221-b11)

Java HotSpot(TM) Client VM (build 25.221-b11, mixed mode)



然后再次执行刚刚的命令

执行命令:

cd ~/kafka_2.12-1.1.0/

bin/kafka-console-producer.sh --broker-list {你的kafka broker地址} --topic {生产消息的topic(之前创建的名称)}



新建终端!

执行命令:

cd ~/kafka_2.12-1.1.0/

bin/kafka-console-consumer.sh --bootstrap-server {你的kafka broker地址} --topic {生产消息的topic(之前创建的名称)} --group test_grp --consumer-property enable.auto.commit=true --from-beginning


【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。