一、环境准备

Centos7， 1 CPU ， 2G Memory ，20G Disk ， Virtual System
Hosts ： node110, node111 , node112
全部配置JDK
配置 Zookeeper集群

1.1、Linux环境准备

克隆node110 到node111, node112
修改机器名和IP配置
（有需要可以参考我这篇博客：Hadoop集群部署模式、配置固定IP）

1.2、Zookeeper配置

修改zoo.cfg 配置文件(在zookeeper安装的conf目录下)
node110：（node111、node112一样都要改）
修改myid 配置文件(进入我们建的/opt/apache-zookeeper-3.5.9-bin/zookeeper_data下)
node110结点的值：1
node111结点的值：2
node112结点的值：3
启动
(分别启动三个结点上的zookeeper)

启动成功(三个结点上都有)

然后我们执行./zkServer.sh status，发现最新启动为leader其他两个为flower
(如果出现：Error contacting service. It is probably not running.可能就是你防火墙没关)
验证是集群
node111(./zkCli.sh -server node110:2181):

node112(./zkCli.sh -server node111:2181):

1.3、Kafka配置

修改server.properties 配置文件
node110：

node111：

node112：
清空data 目录
(进入kafka安装目录下)

rm -rf kafka/*

(所有结点都要，这里就演示一个)

启动
分别启动这三个结点的kafka，然后我们可以通过zookeeper 的客户端查看：

二、Kafka常用操作

2.1、Kafka Topcis

创建Topic (2 partitions & 2 replication-factor)
(2个分区、2个复制因子)

bin/kafka-topic.sh --bootstrap-server node110:9092 --partitions integer --replication-factor integer --topic topic-name

(2 partitions & 3 replication-factor)

(3 partitions & 3 replication-factor)

2.2、Kafka Producer && Consumer

1、Producer生产Topic

./kafka-console-producer.sh --broker-list node100:9092,node101:9092,node102:9092 --topic test_02_02

2、Consumer读取Topic

./kafka-console-consumer.sh --bootstrap-server node100:9092 --topic test_02_02 --partition 0 --from-beginning
./kafka-console-consumer.sh --bootstrap-server node100:9092 --topic test_02_02 --partition 1 --from-beginning

./kafka-console-consumer.sh --bootstrap-server node100:9092 --topic test_02_02  --from-beginning

学习笔记Kafka（四）—— Kafka安装配置（3）—— Kafka多代理配置及常用操作相关推荐

linux学习笔记十四：安装SAMBA（Server Message Block）
NFS:仅用于Linux之间 CIFS:仅用于Windows之间 SAMBA:可用于Linux与Windows之间,基于NetBIOS协议(用于LAN内部,不能跨路由),没有IP地址的概念,根据 Ne ...
PCIE学习笔记（四）Xilinx FPGA PCI Express 硬核配置
目录 2.3.2 配置核IP生成 2.3.2.1 Base模式 2.3.2.2 Advanced模式本文主要介绍Xilinx 7系列FPGA的 IP 核配置与应用,使用的工具版本为VIVADO 20 ...
安装成功配置环境变量_go语言学习笔记-Windows10开发环境安装和环境变量配置
相关文档 go语言学习笔记-目录 1.安装 1.1.访问 https://golang.google.cn/dl/ 或 https://golang.org/dl/ 下载官方安装包 1.2.选择Win ...
Boost库学习笔记（一）安装与配置
Boost库学习笔记(一)安装与配置 1. 获取boost https://www.boost.org/users/history/version_1_79_0.html 任选其一 boost的目录结 ...
linux系统管理学习笔记之三----软件的安装
linux系统管理学习笔记之三----软件的安装 2009-12-29 19:10:02 标签:linux 系统管理 [推送到技术圈] 版权声明:原创作品,允许转载,转载时请务必以超链接形式标明文章 ...
PyTorch学习笔记（四）：PyTorch基础实战
PyTorch实战:以FashionMNIST时装分类为例: 往期学习资料推荐: 1.Pytorch实战笔记_GoAI的博客-CSDN博客 2.Pytorch入门教程_GoAI的博客-CSDN博客本 ...
“物联网开发实战”学习笔记-（四）智能音箱制作和语音控制
"物联网开发实战"学习笔记-(四)智能音箱制作和语音控制这次来造一个属于自己的智能音箱,这里详细介绍了智能音箱的语音控制的实现. 智能音箱的技术架构智能音箱主要涉及拾音.前端信 ...
链乔教育在线|智能合约学习——以太坊智能合约学习笔记（四）
链乔教育在线|智能合约学习--以太坊智能合约学习笔记(四) 本笔记记录的是使用matemask钱包连接以太坊私链,并编写一个基本的提币智能合约部署到以太坊私链上,进行调用. 一.浏览器安装metama ...
Docker 学习笔记 - 进阶四 Docker网络和 Docker compose
Docker 学习笔记 - 进阶四 Docker网络和 Docker compose 4. docker 网络 4.1 docker network是什么 4.1.1 docker不启动,默认网络情况 ...
JavaWeb和WebGIS学习笔记（四）——使用uDig美化地图，并叠加显示多个图层
系列链接: Java web与web gis学习笔记(一)--Tomcat环境搭建 Java web与web gis学习笔记(二)--百度地图API调用 JavaWeb和WebGIS学习笔记(三)-- ...

学习笔记Kafka（四）—— Kafka安装配置（3）—— Kafka多代理配置及常用操作

一、环境准备

1.1、Linux环境准备

1.2、Zookeeper配置

1.3、Kafka配置

二、Kafka常用操作

2.1、Kafka Topcis

2.2、Kafka Producer && Consumer

学习笔记Kafka（四）—— Kafka安装配置（3）—— Kafka多代理配置及常用操作相关推荐

最新文章

热门文章