当前位置: 首页 > news >正文

Kafka|基础入门

文章目录

    • 快速了解Kafka
    • 快速上手Kafka
    • 理解Kafka的集群
    • Kafka集群的消息流转模型

快速了解Kafka

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

快速上手Kafka

在这里插入图片描述

在这里插入图片描述

  • 启动zookeeper

在这里插入图片描述

  • 启动kafka

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

  • 创建topic - 启动发送者 - 启动消费者

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

Partition 0:  [msg1] -> [msg2] -> [msg3] -> ...0        1        2Partition 1:  [msg4] -> [msg5] -> ...0        1

在这里插入图片描述
在这里插入图片描述

  • 同一个消费者组中对同一个消息只会消费一次,但是不同的消费者组可以都对一条消息进行消费

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

  • 不同的消费者组会记录自己的一个消费记录offset

在这里插入图片描述

在这里插入图片描述
在这里插入图片描述

理解Kafka的集群

在这里插入图片描述
在这里插入图片描述

  • Broker:Kafka 的服务器实例。
  • Partition:一个 Topic 被划分的最小单位。
  • Leader Partition:每个 Partition 都有一个 Leader,负责处理读写请求。
  • Follower Partition:其余副本称为 Follower,从 Leader 同步数据,主要用于容错。

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

Kafka集群的消息流转模型

在这里插入图片描述

在这里插入图片描述
在这里插入图片描述

相关文章:

  • 企业网站营销如何建设软文营销广告
  • 需要做网站设计百度广告竞价
  • 怎么做网站宣传百度快照是干嘛的
  • the_post() wordpress百度seo排名报价
  • 桓台县城乡建设局网站精准数据营销方案
  • 连云港做网站制作网站优化网
  • Maven-概述-介绍安装
  • Hive数据倾斜优化方法总结
  • ElasticSearch--DSL查询语句
  • C#高级:Winform桌面开发中CheckedListBox的详解
  • Elasticsearch 节点角色详解及协调节点请求策略
  • PHP轻量级聊天室源码(源码下载)
  • 02. [Python+Golang+PHP]三数之和,多种语言实现最优解demo
  • 4、docker compose
  • 全能邮箱全能邮箱:实现邮件管理的自动化!
  • 学习路之PHP--easyswoole安装入门
  • 基于Python flask 的豆瓣电影top250数据评分可视化
  • 深入解析Kafka JVM堆内存:优化策略与监控实践
  • 基于Python与Flask的新能源汽车可视化大屏系统技术解析
  • 基于Flask实现当当网书籍数据分析大屏
  • Science Robotics 具身智能驱动的空中物理交互新范式:结合形态和传感,与非结构化环境进行稳健交互
  • 一台手机怎样实现多IP上网?方法有多种
  • Kafka 客户端连接机制的一个典型陷阱
  • 企业级调度器LVS (面试版)
  • 第十讲 | 继承
  • day37 python早停策略和模型权重的保存