| 失效链接处理 |
|
kafka笔记 PDF 下载
本站整理下载：
相关截图：
主要内容：
一、Kafka原始安装
安装要求: 需要安装jdk
版本：kafka:kafka_2.11-2.4.1.tgz 、zk(使用docker安装,zk 版本:3.4.9)
zk链接工具:ZooInspector
1.1 使用docker安装zk
1.2 安装kafka
1.2.1 上传压缩包到centos
1.2.2 解压压缩文件
1.2.3 修改配置文件
修改配置文件:/kafka2.11-2.4/config/server.properties
搭建kafak集群，主要修改broker.id的值，和修改 端口号即可
1.2.3 启动kafka
使用zk链接工具查看broker信息
$ docker search zookeeper # 查看一下镜像
$ docker pull zookeeper:3.4.9 # 拉取指定版本zk镜像
$ docker images # 查看image ID
$ mkdir -p /docker/zk/data
$ docker run -d -p 2181:2181 -v /docker/zk/data:/data/ --name zookeeper --privileged
3b83d9104a4c # 最后跟着 image ID
$ tar -zxvf kafka_2.11-2.4.1.tgz
#broker.id属性在kafka集群中必须要是唯一
broker.id=0
#kafka部署的机器ip和提供服务的端⼝号
listeners=PLAINTEXT://192.168.3.47:9092
#kafka的消息存储⽂件
log.dir=/usr/local/data/kafka-logs
#kafka连接zookeeper的地址
zookeeper.connect=192.168.3.47:2181
$ cd bin # 进入到bin目录
$ ./kafka-server-start.sh -daemon ../config/server.properties
1.3 测试发送和接收消息
1.3.1 发送消息
kafka-console-producer.sh 这个命令在bin目录下
1.3.2 接收消息
从最后一条消息的偏移量+1开始消费
从头开始消费
1.4 kafka-eagle 监控平台
kafka-eagle-bin-1.2.4.tar.gz
1.4.1 解压文件
1.4.2 配置eagle环境变量
依赖jdk，需要先安装jdk
1.4.3 修改system-config.properties
/usr/local/kafka-eagle/kafka-eagle-bin-1.2.4/kafka-eagle-web-1.2.4/conf/system-config.properties
./kafka-console-producer.sh --broker-list 192.168.3.47:9092 --topic testtopic
$ ./kafka-console-consumer.sh --bootstrap-server 192.168.3.47:9092 --topic testtopic
./kafka-console-consumer.sh --bootstrap-server 192.168.3.47:9092 --from-beginning --
topic testtopic
|
| Java1234官方群25： | 
|
| Java1234官方群25： | 838462530 |
苏公网安备 32061202001004号
