Kafka集群_郑州居家办公全员核酸

Kafka集群_郑州居家办公全员核酸文章目录一、启动集群二、集群验证一、启动集群对于只有一个broker的kafka来说,这就是一个节点数为1的集群。现在,让我们启动一个几点数为3的集群。1、复制出另外两份kafka配置文件cpconfig/server.propertiesconfig/server-1.propertiescpconfig/server.propertiesconfig/server-2.properties#修改server-1.properties中的以下几项配置为broker.id=1li

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全家桶1年46,售后保障稳定

一、启动集群

对于只有一个broker的kafka来说,这就是一个节点数为1的集群。现在,让我们启动一个几点数为3的集群。

1、复制出另外两份kafka配置文件

cp config/server.properties config/server-1.properties
cp config/server.properties config/server-2.properties

# 修改server-1.properties中的以下几项配置为
broker.id=1
listeners=PLAINTEXT://:9093
log.dirs=/tmp/kafka-logs-1

# 修改server-2.properties中的以下几项配置为
broker.id=2
listeners=PLAINTEXT://:9094
log.dirs=/tmp/kafka-logs-2

Jetbrains全家桶1年46,售后保障稳定

broker.id是节点在kafka集群中的唯一标识名称,除此之外,我们必须重写端口和日志目录。

2、依次启动zookeeper和三个kafka节点

# 启动zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties

# 启动三个kafka节点,并后台运行
bin/kafka-server-start.sh config/server.properties &

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

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

二、集群验证

1、创建一个topic
现在创建一个复制因子为 3 的新主题:

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

查看该主题详情:
在这里插入图片描述
Leader 1指明集群的主节点是broker.id为1的节点,其负责给定分区的所有读取和写入。

Replicas: 1,2,0指明该主题对应的复制节点应该有哪些,此处表明集群中的三个节点都会同步保存该topic中的记录。

Isr:1,2,0指明该主题对应的复制节点有哪些在实际正常运行,此处表明集群中的三个节点都在正常同步保存该topic中的记录。

2、发送消息到topic

# 发送消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my-replicated-topic

# 打开另一个会话窗口,接收消息
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic my-replicated-topic

干掉当前主节点:
在这里插入图片描述

如果主节点挂了,集群会从从节点中另外选择一个节点来作为主节点,保障集群的正常工作。因此仍然可以通过上面的发送消息命令来发送消息,只不过broker-list需要包含有仍在工作的节点。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/234328.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • eXtremeDB微秒级实时数据库简介「建议收藏」

    eXtremeDB微秒级实时数据库简介「建议收藏」eXtremeDB微秒级实时数据库简介 eXtremeDB实时数据库是美国McObject公司于上世纪九十年代末推出的全世界第一款全内存式实时数据库,特别为高性能、低开销、稳定可靠的极速实时数据管理而设计。 eXtremeDB的性能可以达到微秒一级的惊人速度。eXtremeDB能够达到这样惊人的极限速度,是由其对市场的独特理解、长期的行业经验、持续不断的创新精神和革命性的体系结构等…

  • Fleet究竟是什么?为什么最近这么火~

    Fleet究竟是什么?为什么最近这么火~如何看待JetBrains推出的轻量级编辑器Fleet?

  • 微信表情符号已写入判决书怎么删除_微信100个表情符号含义

    微信表情符号已写入判决书怎么删除_微信100个表情符号含义本文转载自IT之家,IT之家3月3日消息据法治日报报道,如今表情符号已经成为呈堂证供的一部分,登上多地法院判决书等司法文书。报道称,在广东省深圳市中级人民法院发布的一份民事判决书中,对一起涉及微信表情的合同纠纷案作出了判决。作为创作者的卢泓于2018年4月24日向深圳市道一影业集团有限公司法定代表人田民发送其创作的歌词。后者表明其在路上后,发送了微信表情符号[强]。“结合双方的前后聊天内容,一审法院认为该微信表情符号[强]并非是对卢泓歌词的认可,而是属于礼貌性回复,不能

    2022年10月22日
  • java定时器之Timer使用与原理分析[通俗易懂]

    java定时器之Timer使用与原理分析[通俗易懂]Timer和TimerTaskTimer是jdk中提供的一个定时器工具,使用的时候会在主线程之外起一个单独的线程执行指定的计划任务,可以指定执行一次或者反复执行多次。TimerTask是一个实现了Runnable接口的抽象类,代表一个可以被Timer执行的任务。【使用举例】【schedule(TimerTasktask,longdelay)延迟delay毫秒执行】…

  • pycharm2021年激活码刚出【2021最新】

    (pycharm2021年激活码刚出)最近有小伙伴私信我,问我这边有没有免费的intellijIdea的激活码,然后我将全栈君台教程分享给他了。激活成功之后他一直表示感谢,哈哈~https://javaforall.cn/100143.htmlIntelliJ2021最新激活注册码,破解教程可免费永久激活,亲测有效,上面是详细链接哦~MLZP…

  • ROS教程(五):OpenCV调用USB摄像头并发布topic(详细图文)

    ROS教程(五):OpenCV调用USB摄像头并发布topic(详细图文)前言ros教程:OpenCV调用usb摄像头创建功能包教程在ROS教程(三):创建程序包及节点(图文)已讲解,本文便不再细讲。

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号