Kafka实战系列--Kafka的安装/配置

时间:2022-01-28 20:46:03

 

*) 安装和测试

cd /path/to/server
#) 下载kafka二进制包
wget http://apache.fayea.com/apache-mirror/kafka/0.8.1.1/kafka_2.9.2-0.8.1.1.tgz
#) 解压缩kafka包
tar -zxvf kafka_2.9.2-0.8.1.1.tgz
#) 构建软连接到目录kafka
ln -s kafka_2.9.2-0.8.1.1 kafka

#) 开启zookeeper-server服务
bin/zookeeper-server-start.sh config/zookeeper.properties &> /dev/null &
#) 开启kafka-server服务
nohup ./bin/kafka-server-start.sh config/server.properties &> /dev/null &Kafka实战系列--Kafka的安装/配置

#) 进程验证
jps 查询
Kafka实战系列--Kafka的安装/配置
评注:
  QuorumPeerMain 为对应的单个Zookeeper实例
  Kafka 为对应的Kafka实例

netstat 查询
Kafka实战系列--Kafka的安装/配置

评注:
  2181 为zookeeper的监听端口
  9092 为kafka的监听端口

#) 创建topic:test
bin/kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic test
Kafka实战系列--Kafka的安装/配置

#) 列出已创建的topic列表
bin/kafka-topics.sh --list --zookeeper localhost:2181
Kafka实战系列--Kafka的安装/配置

#) 模拟客户端去发送消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testKafka实战系列--Kafka的安装/配置

#) 模拟客户端去接受消息
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginningKafka实战系列--Kafka的安装/配置

简单的一个kafka过程, 还是很容易的

参考官方文档
http://kafka.apache.org/documentation.html