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 #单机可直接用localhost
log.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
?
可以看到刚发送的消息也收到了.