单机环境 搭建 kafka

kafka 搭建环境

官网下载jar 根据需求下载 我用下图标示版本

在 opt 目录下 创建安装目录

将 jar 导入 安装目录下

ls 查看 是否存在jar tar -zvxf 解压

解压完后 vim /etc/profile 配置 kafka

启动zookeeper

nohup bin/zookeeper-server-start.sh config/zookeeper.properties >/dev/null 2>&1 &
//nohup XXXX >/dev/null 2>&1 &是为了在后台启动，否则终端关闭程序就结束了
//这是启动Kafka自带的zookeeper，因为Kafka必须用到zookeeper，否则无法正常启动

&

启动kafka

nohup bin/kafka-server-start.sh config/server.properties >/dev/null 2>&1 &

输入jps，查看进程，如果有kakfa和QuorumPeerMain就表示启动成功了

测试

要是能查看到就说明启动成功了，不放心就进行一下测试。进入到Kafka目录下，输入以下命令

//创建主题：名称为“test”、复制数目为1、partitions为1的topic主题，出现下图所示表示创建成功
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
//查看主题
bin/kafka-topics.sh --list --zookeeper localhost:2181

接着输入以下命令，启动生产者，会出现一个>的符号，表示进入了，然后随便输入字符串bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

打开另一个终端，输入以下命令，启动消费者，会出现刚刚你输入的字符串，那么你的单机Kafka就算配置完成了

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

这是在生产者 输入以下内容

另一个终端中的消费者