网站首页 > 技术文章正文

Centos安装kafka(使用自带的zookeeper)

btikc 2024-10-25 11:01:08 技术文章 6 ℃ 0 评论

1、下载Kafka并解压

wget http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.2.0/kafka_2.11-2.2.0.tgz

tar -zxvf kafka_2.11-2.2.0.tgz

2、Kafka目录介绍

/bin 操作kafka的可执行脚本，不但包含Linux的脚本，还包含windows下脚本；bin下不但有kafka的执行文件，还包括了zookeeper的执行文件。如果你安装zookeeper可以不用使用这里的zookeeper;
/config目录下是配置文件；同样，该目录下有kafka和zookeeper的配置文件。
/libs 依赖库目录;
/logs 日志数据目录，目录kafka把server端日志分为5种类型，分为:server,request,state,log-cleaner,controller;

3，修改配置文件：

zookeeper的配置文件：vim zookeeper.properties

kafka的配置文件：vim server.properties

4，启动

启动zookeeper和kafka：

5，测试验证：

创建\查看topic：

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

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

在控制台使用生产者推送push消息：

./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

在另一控制台使用消费者拉取pull消息，证明成功：

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