Kafka部署

Kafka部署

仅作为Shane个人笔记

  • 去阿帕奇官网下载ZooKeeper和Kafka

配置解压

  • 解压下载的ZooKeeper和Kafka
  • 进入ZooKeeper根目录找到 conf/zoo_sample.cfg文件复制一份改名为zoo.cfg
  • 将其中的dataDir路径设置为自己喜欢的路径
dataDir=/www/server/zookeeper/data
  • 进入Kafka根目录找到 config/server.properties文件
  • 将其中的log.dirs路径设置为自己喜欢的路径
log.dirs=/www/server/kafka/logs

启动ZooKeeper和Kafka

  • 进入ZooKeeper的bin目录
cd /www/server/zookeeper/bin
  • 启动ZooKeeper
./zkServer.sh start # 启动
./zkServer.sh stop # 停止
./zkServer.sh restart # 重启
./zkServer.sh status # 查看运行状态
  • 进入Kafka的bin目录
cd /www/server/kafka/bin
  • 启动Kafka(-daemon为进程守护)
./kafka-server-start.sh -daemon ../config/server.properties

测试

  • 创建一个topic(2个分区)名字命名成test
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 2 --topic test
  • 创建完来看看分区
./kafka-topics.sh --list --zookeeper localhost:2181
  • 启动刚刚创建的topic的producer
./kafka-console-producer.sh --broker-list localhost:9092 --topic test
  • 启动刚刚创建的topic的consumer
# 两个都可以
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning # 显示最初的信息
没有账号? 忘记密码?

社交账号快速登录