学习笔记Kafka—— Kafka安装配置—— Kafka单代理及常用操作

Posted 2021-11-12 别呀

一、Linux环境准备

• Centos7， 1 CPU ， 2G Memory ，20G Disk ， Virtual System
• JDK
• Zookeeper

---

二、Kafka 安装

1. 下载Kafka安装包
   官网：http://kafka.apache.org/downloads

2. 解压安装包 ：tar -zxvf kafka_2.11-2.3.1.tgz -C /opt/

3. 修改配置文件
   进入kafka安装的config目录下：cd /opt/kafka_2.11-2.3.1/config
   修改server.properties文件：
   
   

---

三、Kafka常用操作

3.1、Kafka 启动与关闭

启动
（注意：在启动kafka之前要启动zookeeper服务及zookeeper的客户）
进入kafka安装目录下，执行：

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

启动完成

（新建会话，在Zookeeper目录下执行：bin/zkCli.sh -server node110:2181）

---

3.2、Kafka Producer(生产者)

(记得先启动kafka)

1. Producer创建Topic（建立HelloWorld话题）
   (在kafka的目录下执行)

bin/kafka-console-producer.sh --broker-list node110:9092 --topic HelloWorld

启动完成

3.3、Kafka Consumer(消费者)

1. Consumer读取Topic（消费HelloWorld话题）
   (在kafka的目录下执行)

bin/kafka-console-consumer.sh --bootstrap-server node110:9092 --topic HelloWorld --from-beginning

启动完成

（根据末尾的参数不同，读取到的结果信息数也不同）