1、https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/ 下载安装文件 我这里下载版本是 kafka_2.10-0.10.2.1.tgz

  

2、解压安装文件 tar -zxvf kafka_2.10-0.10.2.1.tgz -C /usr/local

  

3、修改文件夹名字 mv /usr/local/kafka_2.10-0.10.2.1/ /usr/local/kafka

  

4、修改配置文件 vim kafka/config/server.properties 修改内容:

broker.id=0 集群环境 id不能相同

listeners=PLAINTEXT://192.168.74.155:9092

advertised.listeners=PLAINTEXT://192.168.74.155:9092

log.dirs=/usr/local/kafka/kafka-logs

num.partitions=2

zookeeper.connect=192.168.74.155:2181,192.168.74.156:2181,192.168.74.157:2181

kafka是通过zookeeper进行协调集群 必配

  

:wq 保存修改内容

  

5、建立日志文件夹:mkdir /usr/local/kafka/kafka-logs

  

6、启动 zookeeper集群 zkServer.sh start

  

7、启动kafka: /usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties &

  

启动成功

  

可以查看 zookeeper下面的 根节点,会多很多 子节点 zkCli.sh ls /

  

  

=====================================================================================================

  

安装 kafka-manager

1、下载编译好的 kafka-manager-1.0-SNAPSHOT.zip

2、上传到 linux服务器上

解压 unzip kafka-manager-1.0-SNAPSHOT.zip -d /usr/local

改名 mv kafka-manager-1.0-SNAPSHOT kafka-manager-1.0

编辑文件:vim /usr/local/kafka-manager-1.0/conf/application.conf

修改内容:

kafka-manager.zkhosts="192.168.74.155:2181,192.168.74.156:2181,192.168.74.157:2181"

:wq 保存退出

启动kafka-manager:

nohup /usr/local/kafka-manager-1.0/bin/kafka-manager -Dconfig.file=/usr/local/kafka-manager-1.0/conf/application.conf >/dev/null 2>&1 &

默认端口为 :9000

  

  

 

Logo

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

更多推荐