注意：确保有JDK1.8版本及以上

官方文档：https://kafka.apache.org/quickstart

清华镜像下载：https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/

首先下载安装包，在linux及Windows都可以使用。

1. Centos 安装部署

1.1 下载

将下载好的安装包上传至服务器
解压
```
tar -zxvf kafka_2.12-2.6.3.tgz
```

1.2 启动zookeeper

后台启动zookeeper

kafka需要依赖ZK，安装包中已经自带了一个ZK，也可以改成指定已运行的ZK。
如果改成指定的ZK需要修改修改 kafka 安装目录下的 config/server.properties 文件中的zookeeper.connect 。这里使用自带的ZK。
```
nohup ./bin/zookeeper-server-start.sh config/zookeeper.properties >> zookeeper.nohup &
```
检查zookeeper是否启动成功：
```
ps -ef|grep zookeeper
```

1.3 启动Kafka

修改相关配置
```
vim config/server.properties
```
Broker ID启动以后就不能改了
```
broker.id=0
```

取消注释，改成本机IP；如果是云服务器记得开启端口；

# 允许外部端口连接
listeners=PLAINTEXT://0.0.0.0:9092
# 外部代理地址
advertised.listeners=PLAINTEXT://127.0.0.1:9092

num.partitions后面增加2行。
发送到不存在topic自动创建。允许永久删除topic。
```
num.partitions=1
auto.create.topics.enable=true
delete.topic.enable=true
```

后台启动kafka（kafka安装目录下）：

nohup ./bin/kafka-server-start.sh ./config/server.properties >> kafka.nohup &

1.4 创建Topic

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

1.5 查看Topic

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

1.6 启动Producer

新窗口，在Kafka的解压目录下。

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

1.7 启动Consumer

开启一个新的窗口，在Kafka的解压目录下。

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

1.8 测试

2. Windows安装部署

2.1 下载解压

目录结构：

2.2 启动zookeepeer

打开CMD，执行如下命令：

bin\windows\zookeeper-server-start.bat config\zookeeper.properties

2.3 启动Kafka

打开CMD，执行如下命令：

bin\windows\kafka-server-start.bat config\server.properties

2.4 创建Topic

bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafkaTest

2.4 查看Topic

bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

2.5 启动Producer

新开窗口。

bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic kafkaTest

2.6 启动Consumer

新开窗口。

bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafkaTest --from-beginning

2.7 测试

Kafka 安装详解相关推荐

Kafka单机、集群模式安装详解(二)
本文环境如下: 操作系统:CentOS 6 32位 JDK版本:1.8.0_77 32位 Kafka版本:0.9.0.1(Scala 2.11) 接上篇 Kafka单机.集群模式安装详解(一) 6. ...
Linux下boost库的编译、安装详解
1.下载源文件去官网下载:http://www.boost.org/ 这里下载最新版本 wget https://dl.bintray.com/boostorg/release/1.64.0/sou ...
nagios 3.2安装详解（一）
Nagios 安装详解对于运维人员来说,获悉服务器状况的信息非常重要,针对监控服务,比较好的有cacti和nagios,cacti使用更简单一些,cacti主要是用来采集信息,CPU.MEM.流量等 ...
Win10 TensorFlow（gpu）安装详解
Win10 TensorFlow(gpu)安装详解写在前面:TensorFlow是谷歌基于DistBelief进行研发的第二代人工智能学习系统,其命名来源于本身的运行原理.Tensor(张量)意味着 ...
linux下weblogic版本,Linux下weblogic10.3.6（jar）版本安装详解
一.安装前的准备安装weblogic是需要JDK环境的,虽然weblogic有自带的JDK,但是我一般是自己选择JDK进行安装,如果你要自行安装,可以参考我的另一篇博客 https://www.cn ...
Windows 下OpenSSL 安装详解 +图解
Windows 下OpenSSL 安装详解 +图解转载于:https://www.cnblogs.com/zhujiabin/p/5088646.html
CentOS下Hive2.0.0集群模式安装详解
本文环境如下: 操作系统:CentOS 6 32位 Hive版本:2.0.0 JDK版本:1.8.0_77 32位 Hadoop版本:2.6.4 MySQL版本:5.6.30 1. 准备工作 1.1 ...
【Linux开发】Linux下jpeglib库的安装详解
Linux下jpeglib库的安装详解首先要下载所需的库压缩包:jpegsrc.v6b.tar.gz或 jpegsrc.v8b.tar.gz 然后将下载的压缩包随便放在和解压到你喜欢的地方. # t ...
mysql-8.0.12语法_mysql-8.0.12 (免安装版) 安装详解
mysql-8.0.12 (解压版) 安装详解错误解决第一步:mysql-8.0.12 (解压版) 下载地址:https://www.mysql.com/downloads/ 第二步:配置初始化m ...

Kafka 安装详解

1. Centos 安装部署

1.1 下载

1.2 启动zookeeper

1.3 启动Kafka

1.4 创建Topic

1.5 查看Topic

1.6 启动Producer

1.7 启动Consumer

1.8 测试

2. Windows安装部署

2.1 下载解压

2.2 启动zookeepeer

2.3 启动Kafka

2.4 创建Topic

2.4 查看Topic

2.5 启动Producer

2.6 启动Consumer

2.7 测试

Kafka 安装详解相关推荐

最新文章

热门文章