阿里云服务器装kafka 2.13-2.60 从零开始(包含jdk安装配置)

  • Post author:
  • Post category:其他




这里装的版本是kafka2.13-2.60

致谢:https://www.cnblogs.com/tomingto/p/11287566.html

https://blog.csdn.net/futudeniaodan/article/details/86561755



一、Java环境



执行下面的yum指令安装,无线配置环境变量



1.1 安装jdk

1、首先更新一下yum源

yum -y update 

这里比较久(但其实也没有很久

2、列出所有的jdk

yum list Java*

在这里插入图片描述

这里如果有java-1.8.0-openjdk就不用执行后面两个步骤啦

3、列出JDK1.8

yum list java-1.8*

在这里插入图片描述

4、安装jdk1.8(如果有,就不用安装

yum install java-1.8.0-openjdk* -y

在这里插入图片描述



1.2 验证jdk是否安装成功

出现下图则安装成功

在这里插入图片描述



二、kafka安装与使用

https://jingyan.baidu.com/article/03b2f78c31bdea5ea237ae88.html



2.1 下载kafka_2.13-2.60.tgz

点击链接下载:

kafka官网


在这里插入图片描述

直接点击这个二进制文件下载



2.2 安装

Kafka是使用scala编写的运行与jvm虚拟机上的程序,虽然也可以在windows上使用,但是kafka基本上是运行在linux服务器上,因此我们这里也使用linux来开始今天的实战。

首先确保你的机器上安装了jdk,kafka需要java运行环境,以前的kafka还需要zookeeper,新版的kafka已经内置了一个zookeeper环境,所以我们可以直接使用。

说是安装,如果只需要进行最简单的尝试的话我们只需要解压到任意目录即可,这里我们将kafka压缩包解压到/home目录

cd /home

然后,使用shell自带的文件传输工具把本地刚下载的文件放到该目录下(或者命令ftp )

……

接着我们解压:

tar -xzf kafka_2.13-2.6.0.tgz

解压完成,会多出一个目录:

在这里插入图片描述

我们进入该目录:

cd kafka_2.13-2.6.0



2.3 配置

在kafka解压目录下下有一个config的文件夹,里面放置的是我们的配置文件:

在这里插入图片描述

在这里插入图片描述

  • consumer.properites 消费者配置,此处我们使用默认的即可
  • producer.properties 生产者配置,此处我们使用默认的即可
  • server.properties kafka服务器的配置,此配置文件用来配置kafka服务器,目前仅介绍几个最基础的配置:
  1. broker.id 申明当前kafka服务器在集群中的唯一ID,需配置为integer,并且集群中的每一个kafka服务器的id都应是唯一的,我们这里采用默认配置即可。
  2. listeners 申明此kafka服务器需要监听的端口号,如果是在本机上跑虚拟机运行可以不用配置本项,默认会使用localhost的地址,如果是在远程服务器上运行则必须配置,例如:listeners=PLAINTEXT:// 192.168.180.128:9092。并确保服务器的9092端口能够访问。

阿里云端口9092需要自己开启,(不确定是否需要2181端口,反正我顺便都开了)参考这个链接:


开启阿里云服务器端口

  • zookeeper.connect 申明kafka所连接的zookeeper的地址 ,需配置为zookeeper的地址,由于本次使用的是kafka高版本中自带zookeeper,使用默认配置即可。

    zookeeper.connect=localhost:2181



2.4 运行

  • 启动内置zookeeper:
bin/zookeeper-server-start.sh config/zookeeper.properties

在这里插入图片描述

成功后会看到这些……

  • 打开另一个终端会话,并启动kafka:
bin/kafka-server-start.sh config/server.properties

在这里插入图片描述

成功启动所有服务后,您将运行并可以使用基本的Kafka环境。



三、创建第一个消息事件



3.1 创建topic主题

编写第一个事件之前,必须创建一个topic主题。

打开另一个终端会话并运行

bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

Kafka的所有命令行工具都有其他选项:kafka-topics.sh不带任何参数的命令即可显示使用情况信息。例如,它还可以向您显示 详细信息,例如 新主题的分区数:

bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

在这里插入图片描述



3.2 生产者创建主题

bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
>This is my first event
>This is my second event

按ctrl+c即可结束。

在这里插入图片描述



3.3 消费者订阅主题

bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

在这里插入图片描述

按ctrl+c即可结束。

此时生产者发布的消息,消费者就能看到。



ps:一些命令的选项:

在这里插入图片描述

在这里插入图片描述



版权声明:本文为xx__Mor原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。