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

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

废话不多说，直接入正题！

从华为云源下载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