kafka讀書筆記2 Producer生產者

所用版本：2.2.0

producerinterceptor ***

metadata 元資料

serializer & deserializer 序列化和反序列化器

partitioner 分割槽

recordaccumulator 暫存器

構造器

kafkaproducer.send()方法

使用方法

在主類中將producerinterceptor新增到producerinterceptors中，寫入配置

其他

攔截鏈

producerinterceptor：抽象介面

producerinterceptors：類，封裝了producerinterceptor的list

使用方法

在producer主程式中新增

更新

org.apache.kafka.clients.metadata

org.apache.kafka.common.cluster

reference

kafka 2.4 版本

執行緒安全

org.apache.kafka.clients.producer.internals.recordaccumulator

recordaccumulator內部有乙個型別為concurrentmap>的成員變數batches

reference

整個類詳細原始碼：

org.apache.kafka.clients.producer.internals.bufferpool

reference

kafka讀書筆記1 概念

topic partition log partition log 保留策略 retention policy 日誌壓縮 log compaction 日誌壓縮 有時候使用者只關心key最新的value值 broker 在一般的生產環境中，乙個broker獨佔一台物理伺服器 replica 副本 i...

讀書筆記2

關於this指標 雖然this指標大家已經很熟悉了，但是我這裡討論的關於this指標的問題可能大家還沒注意過 為了說明這個關於this的歸屬問題，我自寫了一段再簡單不過的程式，雖簡單但具體 include class a void aa 我的問題是指標p1是指向b自身嗎？一看程式，大家就知道 不是，...

讀書筆記（2）

沉默的藝術 意識科學基礎理論 量子效應只是用於穩定某種內在自由度極大的基本粒子，然後再用基本粒子的內在屬性產生意識體驗。只能通過呈現乙個系統的 物理 屬性來描述乙個系統。只能通過變成內在屬性配對的其中乙個系統，以直接體驗的方式來獲得這些內在屬性的資訊。定義乙個包含所有系統的系統d，除該系統外無任何系...