http_s://kafka.apache.org/downloads

注意安装kafka之前要先去安装jdk,以及zookeeper.

然后我们去官网下载,这里我安装的是:

kafka_2.12-2.8.0.tgz 注意一定要下载这个binary dowloads这个才是编译好的.

​

这里也可以通过wget 的方式来下载安装包

​

可以看到这里kafka,这个下载以后的安装包.

然后去配置:

下载以后重命名这个kafka,重命名成kafka

然后进入config目录

​

然后编辑server.properties文件

log.dirs=/opt/softs/kafka/kafka-logs

​

这个日志目录可以改一下.

​

然后下面的这个

zookeeper.connect=localhost:2181 这个ip地址单机的话可以用localhost,也可以写上ip地址都可以

server.properties修改 内容如下：可直接复制粘贴。broker.id=0 port=9092 #端口号 host.name=localhost #单机可直接用localhostlog.dirs=/DATA/kafka/kafka_2.12-2.0.0/log #日志存放路径可修改可不修改zookeeper.connect=localhost:2181 #zookeeper地址和端口，单机配置部署，localhost:2181 

​

然后再加上这个port=9092

其实按照上面的配置配置就可以了.

​

然后我们在这个kafka文件夹中,创建

kafka-logs文件夹,用来存kafka的日志文件

​

然后再进入:

config目录,然后编辑vim zookeeper.properties文件

​

这里我把maxClientCnxns改成了100,别的没动

还有就是dataDir,这个目录:

​

这里我走到zookeeper目录中,去创建了一个dataDir目录,然后

配置上

​

然后就可以去启动了:

走到对应的kafka目录中去:

然后进入bin目录

./kafka-server-start.sh /opt/softs/kafka/config/server.properties &

这样执行.

​

可以看到启动成功了.

启动了以后,我们再去:

测试一下kafka是否能用:

​

1.创建一个topic去

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

2.然后查看一下topic列表

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

3.然后向测试的topic中发送个消息

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

4.然后用消费者去接收消息

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

​

可以看到刚发送的消息也收到了.