惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

F
Fortinet All Blogs
宝玉的分享
宝玉的分享
酷 壳 – CoolShell
酷 壳 – CoolShell
T
The Exploit Database - CXSecurity.com
Help Net Security
Help Net Security
腾讯CDC
Project Zero
Project Zero
C
CXSECURITY Database RSS Feed - CXSecurity.com
IT之家
IT之家
C
Cyber Attacks, Cyber Crime and Cyber Security
T
Tailwind CSS Blog
Threat Intelligence Blog | Flashpoint
Threat Intelligence Blog | Flashpoint
D
Darknet – Hacking Tools, Hacker News & Cyber Security
L
LINUX DO - 最新话题
K
KPMG report finds enterprise disconnect between AI and its ROI | CIO
T
Threatpost
N
News | PayPal Newsroom
C
Cybersecurity and Infrastructure Security Agency CISA
Hacker News - Newest:
Hacker News - Newest: "LLM"
S
SegmentFault 最新的问题
cs.AI updates on arXiv.org
cs.AI updates on arXiv.org
P
Proofpoint News Feed
A
Arctic Wolf
B
Blog RSS Feed
Forbes - Security
Forbes - Security
P
Privacy & Cybersecurity Law Blog
Attack and Defense Labs
Attack and Defense Labs
V2EX - 技术
V2EX - 技术
P
Proofpoint News Feed
I
Intezer
Application and Cybersecurity Blog
Application and Cybersecurity Blog
阮一峰的网络日志
阮一峰的网络日志
aimingoo的专栏
aimingoo的专栏
T
Tenable Blog
MyScale Blog
MyScale Blog
U
Unit 42
Cyber Security Advisories - MS-ISAC
Cyber Security Advisories - MS-ISAC
WordPress大学
WordPress大学
W
WeLiveSecurity
D
DataBreaches.Net
奇客Solidot–传递最新科技情报
奇客Solidot–传递最新科技情报
G
GRAHAM CLULEY
有赞技术团队
有赞技术团队
Martin Fowler
Martin Fowler
罗磊的独立博客
The Last Watchdog
The Last Watchdog
让小产品的独立变现更简单 - ezindie.com
让小产品的独立变现更简单 - ezindie.com
V
Vulnerabilities – Threatpost
美团技术团队
Microsoft Security Blog
Microsoft Security Blog

博客园 - Rickie

DeepSeek-V3 解读:优化效率与规模 一步一步构建RAG智能问答系统 Milvus向量数据库入门实践 LangChain轻松入门和开发实践 Hugging Face 轻松入门 PyTorch深度学习零基础入门 Spring Security OAuth2+JWT开发实践 Spring Security开发实践 Redis 7.x 入门和开发实战 RedisInsight :Redis 官方可视化工具 Hadoop v3.1 大数据技术快速入门 《Apache RocketMQ 深入浅出》系列文章 Apache Doris 轻松入门和快速实践 一步一步编译最新版Apache Doris 0.15版本的详细过程 COLA 4.x和DDD项目实践精粹 阿里开源COLA 4.0源码编译和部署过程 Java实体映射工具MapStruct 与BeanUtils性能比较 阿里DDD项目最佳实践-COLA 架构总览 Java实体映射工具MapStruct详解
Kafka v2.3 快速入门与实践
Rickie · 2022-03-19 · via 博客园 - Rickie

消息队列应用场景:应用解耦、异步消息、流量削峰等问题,实现高性能、高可用、可伸缩和最终一致性架构。

Kafka是由LinkedIn开发的一个分布式的消息系统,可独立部署在单台服务器上,也可部署在多台服务器上构成集群。它提供了发布与订阅功能。用户可以发送数据到Kafka集群中,也可以从Kafka集群中读取数据。Kafka使用Scala编写,它以可水平扩展和高吞吐率而被广泛使用。

目前越来越多的开源分布式处理系统如Storm,Spark,Flink都支持与Kafka集成。现在我们的数据实时处理平台也使用到了Kafka。现在它已被多家不同类型的公司作为多种类型的数据管道和消息系统使用。

如下是Kafka消息中间件的架构图:

本技术专栏从实战出发,通过零基础入门-环境搭建-项目案例实战,让初学者快速掌握Kafka相关技术要点并投入实际项目开发,其中包括Kafka安装和配置、Kafka基本组件的实现机制、Zookeeper和控制器Controller、Kafka消息生产者和消息者的代码实现、以及和Spring Boot的集成开发、Kafka 可视化客户端工具Kafka Tool 2(Offset Explorer)和Kafka Eagle、Kafka Connect 连接器和Debezium等等。

专栏主要包含如下内容:

  • 快速了解消息队列和Kafka基本概念、使用场景、以及性能好的原因

  • Kafka v2.3.1 安装、配置、启动和基本操作

  • 安装和配置Kafka集群开源的可视化监控工具-Kafka Eagle

  • Kafka broker 开启 JMX监控

  • Kafka基本组件的实现机制,为什么要将Topic进行分区?如何保证高可靠性?

  • Kafka的元数据存储Zookeeper以及控制器Controller

  • Kafka v2.3.1通过客户端API实现简单生产者和消费者

  • Kafka生产者Producer使用异步模式发送消息

  • Kafka生产者Producer使用多线程发送消息

  • Kafka消息发送的主要步骤、配置参数、以及如何保证消息有序?

  • Kafka v2.3.1通过spring-kafka实现生产者和消费者

  • Kafka v2.3和Spring Boot v2.2.1使用@KafkaListener实现单条或批量接收消息

  • 深入了解spring-kafka中核心技术概念-消息监听器、监听器容器并发数、@KafkaListener注解等等

  • spring-kafka 操作Topic以及可视化监控工具Kafka Eagle的使用

  • Kafka v2.3和Spring Boot v2.2.1集成项目示例源代码

  • Kafka可视化客户端工具Kafka Tool 2的基本使用

  • Kafka 在生产者Producer中实现并使用自定义分区器Partitioner

  • 图文并茂演示如何通过Kafka Connect连接器建立数据管道

  • 图文并茂演示Kafka Connect在分布式模式下将数据导入/导出Kafka Topic

  • Debezium和Kafka Connect实现MySQL数据高效实时同步Kafka Topic

  • Kafka Stream快速入门和实例项目WordCount详细演示