首页
学习
活动
专区
圈层
工具
发布
    • 综合排序
    • 最热优先
    • 最新优先
    时间不限
  • 来自专栏大数据那些年

    教你快速搭建Kafka集群2)——Kafka集群安装部署

    上一篇快速认识Kafka阶段(1)——最详细的Kafka介绍给大家简单介绍了消息队列和kafka的一些基本内容,下面教大家怎样去安装部署Kafka集群哦!!!!!! 码字不易 先点个赞吧! ? host.name=node03 6、kafka集群启动与停止 注意事项:在kafka启动前,一定要让zookeeper启动起来。 /server.properties 2>&1 & ? 三台机器也可以执行以下命令停止kafka集群 cd /export/servers/kafka_2.11-1.0.0 bin/kafka-server-stop.sh 以上就是kafka集群搭建, 其实很简单,接下来给大家更新 kafka集群的操作,点个关注点个赞再走吧!!!

    92830发布于 2021-04-13
  • 来自专栏大数据成长之路

    快速入门Kafka系列(2)——Kafka集群搭建

    作为快速入门Kafka系列的第二篇博客,本篇为大家带来的是Kafka集群搭建~ 码字不易,先赞后看! ? ---- Kafka 集群环境搭建 1、初始化环境准备 安装jdk,安装zookeeper并保证zk服务正常启动。 集群规划 node01 node02 node03 zk zk zk kafka kafka kafka 2、下载安装包并上传解压 通过以下地址进行下载安装包 node01 集群启动与停止 注意事项: 在kafka启动前,一定要让zookeeper启动起来。 bin/kafka-server-start.sh config/server.properties 2>&1 & 三台机器也可以执行以下命令停止kafka集群 cd /export/servers/kafka

    85110发布于 2021-01-27
  • 来自专栏不温卜火

    Kafka快速入门系列(2) | Kafka集群部署(超级简单!!!)

      经过上篇的简单介绍,相信大家对Kafka有了初步的了解,本篇为博主带来的是Kafka集群部署。 需要的东西博主都已经打包上传到百度云了,如有需要的可以通过链接自取: 链接:https://pan.baidu.com/s/1YtXgkt2430leNgCaNf2SLQ 提取码:jnwl 一. 1.集群规划 hadoop002 hadoop003 hadoop004 zk zk zk kafka kafka kafka 2. 所需包 ? 二. Kafka集群部署 1. 解压安装包 [bigdata@hadoop002 Kafka]$ tar -zxvf kafka_2.11-0.11.0.2.tgz -C /opt/module/ 2. 启动集群 [bigdata@hadoop002 kafka]$ bin/kafka-server-stop.sh stop [bigdata@hadoop003 kafka]$ bin/kafka-server-stop.sh

    96920发布于 2020-10-28
  • 来自专栏全栈程序员必看

    kafka 集群配置_kafka集群原理

    2集群介绍 (1)Kafka架构是由producer(消息生产者)、consumer(消息消费者)、borker(kafka集群的server,负责处理消息读、写请求,存储消息,在kafka cluster (2kafka里面的消息是有topic来组织的,简单的我们可以想象为一个队列,一个队列就是一个topic,然后它把每个topic又分为很多个partition,这个是为了做并行的,在每个partition kafka中有一个被称为优先副本(preferred replicas)的概念。如果一个分区有3个副本,且这3个副本的优先级别分别为0,1,2,根据优先副本的概念,0会作为leader 。 kafka_2.11-1.1.0.tgz 去下载 在node01上 /opt/bigdata/下 解压 tar zxvf kafka_2.11-1.1.0.tgz (2)编辑配置 在/opt/bigdata (4)启动kafka集群 kafka集群启动前要启动zookeeper集群,若zookeeper集群没启动,首先启动 在/opt/bigdata下 ,三个节点分别执行如下命令,启动kafka集群 .

    1.7K20编辑于 2022-09-27
  • 来自专栏JAVA同学会

    kafka集群搭建

    一、zookeeper集群搭建   略,请参考其他文档,这里不再赘述。 二、下载kafka   从kafka官网下载kafka_2.11-0.11.0.0.tgz,并解压。 tar -zxvf kafka_2.11-0.11.0.0 三、kafka配置修改   这里我们仅以两台kafka实例做集群。    四、kafka集群启动   nohup ${kafka_home}/bin/kafka-server-start.sh ${kafka_home}/config/server.properties &   将两台机器的kafka启动,集群搭建完毕。    集群搭建就是这么简单。

    84520发布于 2019-02-25
  • 来自专栏python3

    kafka集群搭建

    看上面一张图,要想做kafka集群,有几个关键点 1. 所有kafka节点,必须连接到同一个Zookeeper(可以是单机,也可以是Zookeeper集群) 2kafka节点配置文件中的broker.id必须唯一,如上图 3. kafka节点的数量,必须是奇数 关于zookeeper集群的搭建,请参考链接: https://www.cnblogs.com/xiao987334176/p/10103619.html 本文使用5个kafka节点,构造kafka集群 集群 在启动kafka之前,请确保已经启动了3台zk服务器。 d874f6d1ef6c        kafka_cluster       "/run.sh"           2 minutes ago       Up 2 minutes        

    1.3K10发布于 2020-02-21
  • 来自专栏IfDataBig

    2.基于Zookeeper搭建Kafka高可用集群

    一、Zookeeper集群搭建 为保证集群高可用,Zookeeper 集群的节点数最好是奇数,最少有三个节点,所以这里搭建一个三个节点的集群。 server.1=127.0.0.1:2287:3387 server.2=127.0.0.1:2288:3388 server.3=127.0.0.1:2289:3389 如果是多台服务器,则集群中每个节点通讯端口和选举端口可相同 二、Kafka集群搭建 2.1 下载解压 Kafka 安装包官方下载地址:http://kafka.apache.org/downloads ,本用例下载的版本为 2.2.0,下载命令: # 下载 wget 2.4 启动集群 分别指定不同配置文件,启动三个 Kafka 节点。启动后可以使用 jps 查看进程,此时应该有三个 zookeeper 进程和三个 kafka 进程。 bin/kafka-server-start.sh config/server-1.properties bin/kafka-server-start.sh config/server-2.properties

    69620编辑于 2022-07-27
  • 来自专栏大数据组件部署

    kafka集群部署

    集群规划Kafka 是一个开源的分布式消息队列系统,主要用于处理和传输大量的数据流。通俗来说,它就像一个“邮局”或者“快递公司”,负责在不同的应用程序之间发送和接收信息。 前提工作我们采用kafka3.3版本(kafka_2.12-3.3.1.tgz)hadoop102下解压缩cd /opt/module# 解压tar -zxvf kafka_2.12-3.3.1.tgz # 重命名mv kafka_2.12-3.3.1/ kafka配置环境变量# 编辑配置文件vim /etc/profile# KAFKA_HOMEexport KAFKA_HOME=/opt/module ,路径不需要提前创建,kafka自动帮你创建,可以配置多个磁盘路径,路径与路径之间可以用","分隔log.dirs=/opt/module/kafka/datas#配置连接Zookeeper集群地址(在 #broker对外暴露的IP和端口 (每个节点单独配置)advertised.listeners=PLAINTEXT://hadoop103:9092# hadoop104 如下:broker.id=2#

    47521编辑于 2024-08-07
  • 来自专栏用户8794315的专栏

    kafka 集群部署

    kafka1 172.17.6.15 kafka2 172.17.6.16 kafka3 二、部署zookeeper集群1.下载安装tar -zxf zookeeper-3.4.14 server.1=kafka1:2888:3888server.2=kafka2:2888:3888server.3=kafka3:2888:38883. systemctl start zookeeper systemctl enable zookeeper 三、部署kafka集群这里生产环境使用kafka_2.11-2.2.0 来进行部署1.下载安装 20 --replication-factor 3 --config x=y 注 :此命令是在kafka部署目录中操作参数 详解 :--bootstrap-server : kafka集群地址--create :master 参数说明: KAFKA_CLUSTERS_0_NAME=kafka1 表示 第一个集群

    2.1K30编辑于 2023-07-18
  • 来自专栏武培轩的专栏

    搭建Kafka集群

    下载Kafka 1.下载Kafka:http://mirror.bit.edu.cn/apache/kafka/2.3.0/kafka_2.12-2.3.0.tgz 2.解压后复制Kafka文件夹,分别命名为 kafka1、kafka2kafka3 修改配置文件 修改config文件夹下的server.properties ,其中的brokerId是惟一的,集群kafka服务器配置的brokerId不能相同 集群的服务器端口号, /kafka是在zookeeper挂载的文件夹,要自己创建zookeeper客户端命令 create /kafka Kafka操作 创建主题 kafka-topics.bat :设置主题名字 查看主题状态 kafka-topics.bat –describe –zookeeper 127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183/kafka –topic test 结果信息字段含义: 1 Partition: 分区 2 Leader : 负责读写指定分区的节点 3 Replicas : 复制该分区log的节点列表 4 Isr :

    1.2K30发布于 2019-08-31
  • 来自专栏Jed的技术阶梯

    Kafka集群搭建

    ---- 环境准备 服务器集群 我用的CentOS-6.7版本的3个虚拟机,主机名为hadoop01、hadoop02、hadoop03,这3台虚拟机既是zookeeper集群,又是kafka集群(但在生产环境中 /kafka_2.11-0.10.2.1.tgz -C /opt/apps/ 2. 单节点或者伪分布式集群中不需要配置 broker.id在每个节点上是唯一的,我设置的hadoop01的broker.id=1,hadoop02的broker.id=2,hadoop03的broker.id 测试kafka集群 (1) 在任意节点上创建"test01"这个topic [hadoop@hadoop01 kafka_2.11-0.10.2.1]$ bin/kafka-topics.sh \ -- Kafka集群搭建成功!

    1.6K10发布于 2018-09-13
  • 来自专栏后台技术杂项笔记

    kafka集群搭建

    基于docker-compose的kafka集群搭建 使用docker-compose搭建kafka集群,解析一些参数含义及列出搭建过程的一些坑。 KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka2:9092 BOOTSTRAP_SERVERS: kafka1:9091,kafka2 - kafka3 2. 答案是有的,在Dockerfile其已经安装了docker 2.3. kafka_manager 用来管理kafka集群的,在容器启动后可以通过localhost:9000访问可视化界面。 注意创建时由于上面docker-compose.yml中已经设置将所有的kafka集群信息放在/kafka目录下,所以这里也要加上/kafka后缀 但这里有一个坑,就是在创建集群后会遇到如下错误 Yikes

    94210编辑于 2022-09-26
  • 来自专栏全栈程序员必看

    Kafka 集群搭建

    1、前提条件 1、部署Kafka集群搭建需要服务器至少3台,奇数台 2Kafka的安装需要java环境,jdk1.8 3、Kafka安装包版本:kafka _2.11-0.10.0.1.tar.gz 4、假设3台服务器分别为:kafka1、kafka2kafka3 2、Zookeeper集群搭建 1、将安装包kafka_2.11 ,server.1、server.2、server.3 为集群信息。 .sd.cn:3181,kafka2.sd.cn:3181,kafka3.sd.cn:3181 #zookeeper连接地址,多个以逗号隔开 9、启动kafka集群: &>> /opt/kafka_2.11-0.10.0.1/kafka.log & 10、测试Kafka集群 1、创建topic:test /opt/

    1.9K10编辑于 2022-08-11
  • 来自专栏HUC思梦的java专栏

    Kafka集群搭建

    一、Kafka集群搭建 1、环境构建  安装kafka集群之前,确保zookeeper服务已经正常运行,这里3台zookeeper准备工作都已完成,三台主机分别为:192.168.3.220,192.168.3.221,192.168.3.222 /kafka/config vim server.properties 修改配置文件的以下属性 ## 强调这个ID在集群中必须是唯一否则会出现ID冲突问题 broker.id=0 ## 配置kafka :/usr/local/ 并修改上面配置文件的属性 broker.id和listeners就OK 3、启动kafka集群 /usr/local/kafka/bin/kafka-server-start.sh /kafka/config/server.properties 4、测试kafka集群 4.1、创建和查看消息主题 连接zookeeper,创建一个名为test-topic的topic sh kafka-topics.sh 集群,以host:port形式,多个以逗号分隔host1:port1,host2:port2; acks:生产者需要server端在接收到消息后,进行反馈确认的尺度,主要用于消息的可靠性传输;acks

    2.3K10发布于 2020-09-03
  • 来自专栏ops技术分享

    kafka集群部署

    一.环境准备 当前环境:centos7.3三台 软件版本:kafka_2.12 部署目录:/usr/local/kafka 启动端口:9092 配置文件:/usr/local/kafka/config/ server.properties yum依赖(3台同时操作) yum install java-1.8.0-openjdk 需要部署zookeeper集群 二.安装 1.下载kafka包(3台节点都执行 ) wget http://mirror.bit.edu.cn/apache/kafka/0.10.2.1/kafka_2.12-0.10.2.1.tgz 2.解压并移动,然后创建日志目录(3台节点都执行 ) tar zxvf kafka_2.12-0.10.2.1.tgz mv kafka_2.12-0.10.2.1 /usr/local/kafka mkdir /var/log/kafka 3.修改配置文件 (3台同时操作,需要更改的地方不一样) vim /usr/local/kafka/config/server.properties #此为第一台,第二台为2 第三台为3 broker.id=1 # Switch

    65030发布于 2021-07-06
  • 来自专栏戴言泛滥

    Kafka集群搭建

    kafka集群需要jdk和zookeeper环境 可参考: vmware15安装centos7 Zookeeper集群搭建 下载kafka wget https://mirrors.bfsu.edu.cn /apache/kafka/2.8.0/kafka_2.13-2.8.0.tgz 根据自己的习惯创建一个路径用来存放kafka程序 我选择的是/usr/tools/ 然后执行解压命令 tar -zxvf /server.properties 修改配置文件中的broker.id分别为1、2、3 并将三台服务器中的以下配置属性都配制成下边的参数 #数据的存放路径,也可以使用默认的 log.dirs=/usr /tools/kafka_2.13-2.8.0/kafka-logs #默认topic分区的数量 num.partitions=3 #zookeeper集群的地址和端口,多个地址和端口之间用逗号相连 zookeeper.connect 搭建并启动成功 ps: 可以使用nohup命令启动kafka,这样即使关闭窗口也能保证kafka正常运行 nohup /usr/tools/kafka_2.13-2.8.0/bin/kafka-server-start.sh

    1K30发布于 2021-06-10
  • 来自专栏迁移内容

    Kafka集群部署

    0、环境准备 安装jdk,配置环境 提前安装zookeeper 1、解压安装 将tar压缩包上传 tar -zxvf kafka_2.12-2.5.0.tgz 2、配置变量环境 vi /etc/profile #kafka export KAFKA_HOME=/usr/local/apps/kafka_2.12-2.5.0 export PATH=$PATH:$KAFKA_HOME/bin source / num.recovery.threads.per.data.dir=1 #segment文件保留的最长时间,超时将被删除 log.retention.hours=168 #配置连接Zookeeper集群地址 # 需要求改成自己的 zookeeper.connect=Carlota1:2181,Carlota2:2181,Carlota3:2181 4、启动集群 [root@carlota1]$ zkServer.sh -daemon $KAFKA_HOME/config/server.properties [root@carlota1]$ kafka-server-start.sh -daemon $KAFKA_HOME

    57430编辑于 2022-12-01
  • kafka集群部署

    基础架构 特点 高吞吐量、低延迟:kafka每秒可以处理几十万条消息,它的延迟最低只有几毫秒 可扩展性:kafka集群支持热扩展 持久性、可靠性:消息被持久化到本地磁盘,并且支持数据备份防止数据丢失 容错性 :允许集群中节点失败(若副本数量为n,则允许n-1个节点失败) 高并发:支持数千个客户端同时读写 集群部署 服务器IP地址 节点名称 192.168.124.171 kafka1 192.168.124.172 kafka2 192.168.124.173 kafka3 在3.5版本发布后,Zookeeper已被标记为弃用并推荐使用KRaft模式部署kakfa集群,但是官方手册也提到了KRaft中仍有一小部分功能有待实现 ,所以个人还是推荐在生产环境中使用zookeeper模式部署kafka集群。 server.2=192.168.124.172:2888:3888 server.3=192.168.124.173:2888:3888 创建目录和myid 根据zoo.cfg中的server.N配置项

    48810编辑于 2025-03-05
  • 来自专栏Cyylog技术

    kafka集群搭建

    Apache Kafka相对于ActiveMQ是一个非常轻量级的消息系统,除了性能非常好之外,还是一个工作良好的分布式系统 相关概念 producer: 消息生产者,发布消息到 kafka 集群的终端或服务 broker: kafka 集群中包含的服务器。 topic:每条发布到 kafka 集群的消息属于的类别,即 kafka 是面向 topic 的。 kafka 分配的单位是 partition。 consumer: 从 kafka 集群中消费消息的终端或服务。 controller: kafka 集群中的其中一个服务器,用来进行 leader election 以及 各种 failover。 zookeeper: kafka 通过 zookeeper 来存储集群的 meta 信息 单实例Kafka 前提条件:安装JDK、设置JAVA_HOME、PATH环境变量。

    1K10发布于 2020-08-19
  • 来自专栏全栈程序员必看

    Kafka集群原理

    Kafka 是一个分布式的、可水平扩展的、基于发布/订阅模式的、支持容错的消息系统。 一、集群成员 Kafka 使用 Zookeeper 来维护集群成员的信息。 Kafka 组件订阅 Zookeeper 的 /broker/ids 路径,当有 broker 加入集群或退出集群时,这些组件就可以获得通知。 三、控制器 控制器组件(Controller),是 Apache Kafka 的核心组件。它的主要作用是在 ZooKeeper 的帮助下管理和协调整个 Kafka 集群。 简而言之,Kafka 使用 Zookeeper 的临时节点来选举控制器,并在节点加入集群或退出集群时通知控制器。控制器负责在节点加入或离开集群时进行 Partition Leader 选举。 通常要再额外预留出 2/3 的资源,即单台服务器使用带宽 700Mb / 3 ≈ 240Mbps。可以计算 1 小时内处理 1TB 数据所需的服务器数量了。

    1.7K51编辑于 2022-08-10
领券