1.本次选用3台机器测试

10.58.22.219 fk01
10.58.22.221 S1PA124
10.58.22.220 S1PA123

2.安装好zookeeper-3.4.6

  zookeeper安装也很简单,在此就省略了

3.安装kafka

安装文件准备

   (1)下载kafka_2.9.2-0.8.1.1.tar.gz

   (2)解压缩 tar -zxvf kafka_2.9.2-0.8.1.1.tar.gz

   (3)复制到另外两台机器

scp -r kafka_2.10-0.8.1 root@fk01:/root/install/
scp -r kafka_2.10-0.8.1 root@S1PA123:/root/install/
环境配置

  (1)修改server.properties

     broker.id:  唯一标识(S1PA124=221,fk01=219,S1PA123=220)

     host.name:为当前机器的IP地址或主机名

   (2)配置zookeeper访问地址

     zookeeper.connect=S1PA124:2181,S1PA123:2181,fk01:2181

  (3)log.dirs=数据存放目录

4.启动服务

(1)在每台机器上先启动zookeeper服务

   bin/zkServer.sh start
(2)接着在每台机器上启动kafka服务

 bin/kafka-server-start.sh config/server.properties

5.简单的使用

(1)创建topic

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

(2)查看topic

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

(3)查看详细的topic
  bin/kafka-topics.sh --describe --zookeeper 10.58.22.221:2181
(4)删除Topic
bin/kafka-run-class.sh kafka.admin.DeleteTopicCommand --topic hello-kafka --zookeeper fk01:2181,S1PA124:2181,S1PA124:2181

 

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐