CentOS7 安装 Kafka

﹏ヽ暗。殇╰゛Y 2022-06-13 12:27 140阅读 0赞

安装Kafka之前，需要安装Scala.

# 安装Scala #

## 下载Scala ##

1.scala下载地址

[https://www.scala-lang.org/download/][https_www.scala-lang.org_download]

➜ cd /opt/software
    
    ➜ wget https://downloads.lightbend.com/scala/2.12.7/scala-2.12.7.tgz

## 2. 解压 ##

➜ tar -zxvf scala-2.12.7.tgz

## 3.配置profile环境 ##

➜ vim /etc/profile

在文件尾部，添加如下配置：

export SCALA_HOME=/opt/software/scala-2.12.7
    
    export PATH=$PATH:$SCALA_HOME/bin

## 4.重新编译profile ##

使配置生效

➜ source /etc/profile

## 5.查看scala版本 ##

➜ scala -version

# 安装Kafka #

官方下载地址

[http://kafka.apache.org/downloads][http_kafka.apache.org_downloads]

下载二进制包，选择Scala 2.12版本的。

## 1.下载Kafka ##

➜ cd /opt/software
    
    
    ➜ wget http://mirror.bit.edu.cn/apache/kafka/2.1.0/kafka_2.12-2.1.0.tgz

## 2.解压 ##

➜ tar zxvf kafka_2.12-2.1.0.tgz
    
    ➜ mv kafka_2.12-2.1.0 kafka
    
    ➜ cd kafka

# 功能验证 #

## 1.启动 Zookeeper ##

使用安装包中的脚本启动单节点Zookeeper 实例：

➜ bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

## 2.启动 Kafka 服务 ##

[使用kafka-server-start.sh][kafka-server-start.sh] 启动kafka 服务：

➜ bin/kafka-server-start.sh config/server.properties

## 3.创建topic ##

[使用kafka-topics.sh][kafka-topics.sh] 创建单分区单副本的topic test：

➜ bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

查看topic：

➜ bin/kafka-topics.sh --list --zookeeper localhost:2181
    
    test

## 4.产生消息 ##

[使用kafka-console-producer.sh][kafka-console-producer.sh] 发送消息：

➜ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 
    
    Hello world！

## 5.消费消息 ##

[使用kafka-console-consumer.sh][kafka-console-consumer.sh] 接收消息并在终端打印：

➜ bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
    
    Hello world!

![这里写图片描述][SouthEast]

[https_www.scala-lang.org_download]: https://www.scala-lang.org/download/
[http_kafka.apache.org_downloads]: http://kafka.apache.org/downloads
[kafka-server-start.sh]: http://xn--kafka-server-start-hx72af326c.sh
[kafka-topics.sh]: http://xn--kafka-topics-ov8s4133b.sh
[kafka-console-producer.sh]: http://xn--kafka-console-producer-oy39a8826c.sh
[kafka-console-consumer.sh]: http://xn--kafka-console-consumer-oy39a8826c.sh
[SouthEast]: /images/20220613/806b17a4cbee427b98f26bf919406464.png