目录

Linux上安装Kafka

当主题删除不了时，可以进入zookeeper：

windows上安装kafka

安装Kafka需要有Zookeeper，或者也可以使用kafka自带的zookeeper

Linux上安装Kafka

将kafka的安装包上传到/export/server目录并解压，重命名：

tar -zxvf kafka压缩包名

mv kafka压缩包 kafka

1、进入 Kafka 解压目录的 config 目录中

cd /export/server/kafka_2.11-2.0.0/config/

2、利用 vi 或 vim 打开 server.properties 文件

修改：vi server.properties

找到 "broker.id=0"这一行，一般主节点设置为0

找到log.dirs这一行，修改日志存放路径

# broker 的编号，如果集群中有多个broker，则每个broker的编号需要设置的不同
broker.id=0
# broker 对外提供的服务入口地址
listeners=PLAINTEXT://master:9092
# 存放消息日志文件的地址
log.dirs=/opt/kafka_2.12-2.8.1/logs
# Kafka 所需的 ZooKeeper 集群地址
zookeeper.connect=master:2181,slave1:2181,slave2:2181

修改完后，切换到/export/server存放kafka的目录下，分发给两个从节点

scp -r /export/server/kafka/ slave1:/export/server/

scp -r /export/server/kafka/ slave2:/export/server/

分发完后，记得进入两个从节点的 server.properties文件，将broker.id改为1和2

borker.id=1
listeners=PLAINTEXT://slave1:9092
host.name=slave1

borker.id=2
listeners=PLAINTEXT://slave2:9092
host.name=slave2

配置环境变量：vi /etc/profile

export KAFKA_HOME=/export/server/kafka
export PATH=$PATH:$KAFKA_HOME/bin

刷新文件：source /etc/profile

分发给两个从节点：

scp -r /etc/profile slave1:/etc

scp -r /etc/profile slave2:/etc

先启动三台zookeeper： zkServer.sh start 再分别启动三台服务器上的kafka(后台启动命令):

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

jps查看进程是否有kafka节点

经过以上步骤Kafka则安装完成

启动kafka命令：

./bin/kafka-server-start.sh或

./bin/kafka-server-start.sh -daemon config/server.properties（最好用这个）

创建topic，其中toipic名称为installtopic，分区数为2，副本数为2：

./bin/kafka-topics.sh --zookeeper master:2181 --create --replication-factor 2 --partitions 2 --topic installtopic

查看主题：

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

当主题删除不了时，可以进入zookeeper：

//进入Cli端
bin/zkCli.sh -server master:2181
//查看主题
ls /brokers/topics3
//删除主题installtopic
deleteall /brokers/topics/installtopic
//退出Cli端
quit

windows上安装kafka

先在kafka目录下新建一个logs文件夹

修改config\server.properties

listeners=PLAINTEXT://localhost:9092

logs改为自己的路径

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

Windows下启动单机kafka出现：系统找不到指定路径

解决方法：

修改bin\windows\kafka-run-class.bat

rem Which java to use这行下面的

ELSE(

set JAVA="你自己的jdk路径"

）