1. 分區(qū)的概念 在 Kafka 中，主題（Topic）是消息的邏輯分類，而分區(qū)（Partition）則是主題的物理劃分。一個主題可以包含多個分區(qū)，每個分區(qū)是一個有序且不可變...
發(fā)簡信
IP屬地：北京
-
深度剖析Kafka 的分區(qū)機制
-
Kafka 源碼深度解析
1. 整體架構(gòu)概述 Kafka 的整體架構(gòu)主要由 Producer（生產(chǎn)者）、Broker（代理服務(wù)器）、Consumer（消費者）和 ZooKeeper 組成。生產(chǎn)者負責(zé)將...
-
Spring Boot整合Kafka進階：深度剖析交易數(shù)據(jù)與K線生成
在金融市場中，對交易數(shù)據(jù)的實時分析與處理極為關(guān)鍵。通過K線圖，投資者能夠直觀地洞察市場價格走勢，做出更明智的投資決策。本文將深入探討如何借助Spring Boot與Kafka...
-
Spring Boot 整合 Kafka 基礎(chǔ)應(yīng)用
一、引言 Kafka 是一個分布式的流處理平臺，具有高吞吐量、可擴展性和容錯性等特點，廣泛應(yīng)用于日志收集、消息系統(tǒng)、實時數(shù)據(jù)處理等場景。Spring Boot 是一個簡化 S...
-
使用Kafka時一定要注意防止消費速度過慢觸發(fā)rebalance而導(dǎo)致的重復(fù)消費
在Java應(yīng)用中，我們往往會使用spring-kafka組件簡單的設(shè)置一下group_id, topic就開始消費消息了，其實這樣會埋下巨大的安全隱患，即當(dāng)消費速度過慢時有可...
-
搞不定Kafka重復(fù)消費？前言 今天我們聊一個話題，這個話題大家可能在面試過程中，或者是工作當(dāng)中經(jīng)常遇到 :point_right:如何保證 Kafka 消息不重復(fù)消費？我們在做開發(fā)的時候為了程序的健...
-
Kafka如何解決消息丟失問題，消費重復(fù)問題
Kafka簡介： Kafka是一種高吞吐量的分布式發(fā)布訂閱消息系統(tǒng)，它可以處理消費者規(guī)模的網(wǎng)站中的所有動作流數(shù)據(jù)。這種動作（網(wǎng)頁瀏覽，搜索和其他用戶的行動）是在現(xiàn)代網(wǎng)絡(luò)上的許...
-
Kafka在SpringBoot中的整合配置詳解一、Springboot與Spring-kafka版本關(guān)系二、概念知識三、SpringBoot 操作 Kafka 示例 Topic 配置 producer 配置 過濾監(jiān)聽器中...
-
JAVA并發(fā)-自問自答學(xué)ThreadLocal前言 ThreadLocal很多同學(xué)都搞不懂是什么東西，可以用來干嘛。但面試時卻又經(jīng)常問到，所以這次我和大家一起學(xué)習(xí)ThreadLocal這個類。 下面我就以面試問答的形式學(xué)...
-
我讀了這七本書，寫了這篇關(guān)于如何高效閱讀的文章每天一有空閑時間，我就會閱讀微信公眾號的推文，查看當(dāng)天的熱點新聞，還會在晚上下班后，把手機調(diào)成靜音，在家里靜靜地看一個小時的書。然而，看的多了，就會發(fā)現(xiàn)好多文章和書籍，剛開始...
-
玩轉(zhuǎn)EhCache之最簡單的緩存框架一、簡介 Ehcache是一個用Java實現(xiàn)的使用簡單，高速，實現(xiàn)線程安全的緩存管理類庫，ehcache提供了用內(nèi)存，磁盤文件存儲，以及分布式存儲方式等多種靈活的cache管...
-
Maven 用依賴的形式引用第三方Jar包1.執(zhí)行命令 install:install-file -Dfile=jar包路徑 -DgroupId=自定義groupId -DartifactId=自定義artifact...
-
每天讀一遍，二十天后你的情商會突飛猛進！
1.清醒時做事，糊涂時讀書，大怒時睡覺，獨處時思考。 2.話別說太滿，人別熟太快。 3.人前不應(yīng)該說的話，背后也別說。 4.在最憤怒時忍住最傷人對方的那句話。 5.刻薄嘴欠和...
-
記錄點滴的成長！
-
歡迎關(guān)注我的公眾號：程序員追風(fēng)
-
Vue真是太好了 壹萬多字的Vue知識點 超詳細!?1??、Vue和其他兩大框架的區(qū)別 Angular 學(xué)習(xí)成本太高 React 代碼可讀性差 Vue 學(xué)習(xí)成本較低 很容易上手傳送門 https://cn.vuejs.or...
