首页 > 其他分享 >Kafka 万字精讲|工作五年这些你都知道吗?

Kafka 万字精讲|工作五年这些你都知道吗?

时间:2024-01-11 09:59:39浏览次数:32  
标签:万字 消费者 精讲 Partition Kafka 消息 kafka Leader

目录

前言

本文以 Kafka 官方文档 的内容为基石,结合参考文献处文章和笔者自身实践凝练而成,涵盖内容全面,详略得当。

这也是《一文搞懂》系列的第一篇技术长文,期待您的关注。

一、Kafka 简介

一个十分钟的视频带你了解 Kafka

image-20240109164254021

Apache Kafka 是一个开源的分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用。

image-20240109160136265

1.1 事件流平台

  • 什么是事件流

    1. 从技术上讲,事件流是以事件流的形式从数据库、传感器、移动设备、云服务和软件应用程序等事件源实时捕获数据的实践;持久存储这些事件流以供以后检索;实时和回顾性地操作、处理事件流并对其做出反应;并根据需要将事件流路由到不同的目标技术。

    2. 因此,事件流可确保数据的连续流动和解释,以便正确的信息在正确的时间出现在正确的地点。

  • 事件流可以做什么

    1. 实时处理支付和金融交易,例如在证券交易所、银行和保险中。
    2. 连接、存储并提供公司不同部门生成的数据。
    3. 作为数据平台、事件驱动架构和微服务的基础。
    4. 收集客户互动和订单并立即做出反应,等等。
  • Apache Kafka 作为一个事件流平台有什么功能:

    1. 发布(写入)和订阅(读取)事件流,包括从其他系统持续导入/导出数据。
    2. 根据需要持久可靠地存储事件流
    3. 在事件发生时或回顾性地处理事件流。

    标签:万字,消费者,精讲,Partition,Kafka,消息,kafka,Leader
    From: https://www.cnblogs.com/YLTFY1998/p/17957866

相关文章

  • Finance_金蝶KIS专业版全模块精讲
    金蝶KIS专业版全模块精讲https://www.bilibili.com/video/BV19Y4y1X7DD?p=5&vd_source=8b9de621639420a0ceb703aceed712f7  第2节、公共基础设置新增部门 新增用户      第5节、固定资产  ......
  • 15 万字稳定性提升经验:《2023 下半年最佳实践合集》限量申领!
    一分钟精华速览超30位专家共创,近20篇最佳实践,共计15万字。联合所有编写成员正式发布,限量赠送,即日起申领。(方式见文末)为什么整理行业最佳实践?大量实践证明,分布式系统稳定性的提升,不仅仅需要从技术工具发力,还涉及到组织、制度流程、人员能力等方方面面的问题。而每家企业......
  • Kafka消息阻塞:拯救面试的八大终极解决方案!
    大家好,我是小米,一个对技术充满热情的90后程序员。最近在准备社招面试的过程中,遇到了一个超级有挑战性的问题:“Kafka消息阻塞怎么解决?”今天,我就来和大家一起深入剖析这个问题,分享我在解决过程中的心得和经验。认识Kafka消息阻塞首先,我们得了解一下Kafka消息阻塞是什么?简单来说,Kafka......
  • Kafka Streams概述
    ApacheKafka是由Apache软件基金会开发的开源分布式流处理平台。最初是由LinkedIn团队开发,用于处理该公司产生的大量实时数据。Kafka的设计旨在处理大型数据流并提供实时数据处理能力。Kafka基于发布-订阅消息传递模型,生产者将消息发送到主题,消费者订阅这些主题以接收消息......
  • 云消息队列 Kafka 版生态谈第一期:无代码转储能力介绍
    作者:娜米云消息队列 Kafka版为什么需要做无代码转储云消息队列Kafka版本身是一个分布式流处理平台,具有高吞吐量、低延迟和可扩展性等特性。它被广泛应用于实时数据处理和流式数据传输的场景。然而,为了将云消息队列 Kafka版与其他数据源和数据目的地集成,需要额外的开发/组件来......
  • 【flink番外篇】6、flink的WaterMark(介绍、基本使用、kafka的水印以及超出最大允许延
    文章目录Flink系列文章一、watermark介绍1、watermark介绍2、Watermark策略简介3、使用Watermark策略4、处理空闲数据源5、自定义WatermarkGenerator1)、自定义周期性Watermark生成器2)、自定义标记Watermark生成器6、Watermark策略与Kafka连接器7、算子处理Watermark......
  • 【微服务】springboot整合kafka-stream使用详解
    目录一、前言二、kafkastream概述2.1什么是kafkastream2.2为什么需要kafkastream2.2.1对接成本低2.2.2节省资源2.2.3使用简单2.3kafkastream特点2.4kafkastream中的一些概念2.5 KafkaStream应用场景三、环境准备3.1搭建zk3.1.1自定义docker网络3.1.2 拉取zk镜像3.......
  • 7.Kafka,构建TB级异步消息系统
    1.阻塞队列BlockingQueue解决线程通信的问题。阻塞方法:put、take。生产者消费者模式生产者:产生数据的线程。消费者:使用数据的线程。实现类ArrayBlockingQueueLinkedBlockingQueuePriorityBlockingQueue、SynchronousQueue、DelayQueue等。 面试题:写一......
  • debezium+kafka实现mysql数据同步(debezium-connector-mysql)
    1.情景展示在企业当中,往往会存在不同数据库之间的表的数据需要保持一致的情况(数据同步)。如何将A库a表的数据同步至B库a表当中呢?(包含:新增、修改和删除)往往不仅仅需要保持数据的一致性,还要保证数据的即时性,即:A库a表的数据发生变化后,B库a表也能立刻同步变化。实时保持两表数据......
  • Kafka-基本介绍和常见问题
    1、kafka1.1、kafka介绍​kafka是最初由linkedin公司开发的,使用scala语言编写,kafka是一个分布式,分区的,多副本的,多订阅者的消息队列系统。 1.2、kafka相比其他消息队列的优势常见的消息队列:RabbitMQ,Redis,zeroMQ,ActiveMQkafka的优势:1) 可靠性:分布式的,分区,复制和容错的。......