發布/訂閱模式
broker.id=0
logs.dir=/opt/kafka/logs
zookeeper.connect=hadoop102:2181,hadoop103:2181
kafka-producer.sh 生產者
kafka-console-consumer.sh --topic first --bootstrap-server hadoop102:9092
kafka-topics.sh --zookeeper hadoop102:2181 --alter --partitions 4 --topic first
producer傳送訊息封裝的是producerrecord物件。
分割槽原則
分割槽分配策略
offset維護
public
class
customproducer
producer.
close()
;}}
public
class
syncproducer()
producer.
close()
;}}
public
class
customconsumer()
} consumer.
commitasync()
;//非同步提交offset
同步提交offset
}}
public
class
timeinterceptor
implements
producerinterceptor
@override
public
void on acknowledgement
(recordmetadata metadata, exception exception)
else
}@override
public
void
close()
@override
public
void
configure
(map?> configs)
}//在生產者中指定***即可,多個可用逗號分割
"com.***.***.timeinterceptor");
hw，leo分別是什麼？
怎麼體現訊息順序性
kafka中的分割槽器，序列化，***的了解以及執行順序
生產者客戶端的結構是什麼樣子？用了幾個執行緒來處理？分別是什麼？
消費者個數如果超過topic分割槽，那麼就會有消費者消費不到資料，怎麼理解？
消費者提交消費位移是當前訊息的offset還是offset+1？
哪些情形會造成重複消費？
哪些情形會造成漏消費？
建立topic的步驟
topic的分割槽數可以增加嗎？
kafka有內部的topic嗎？
分割槽分配的概念？
kafka controller的作用？
什麼地方需要選舉？
失效副本是什麼？怎麼應對？
kafka 的哪些設計提高效能
Linux知識點梳理
使用者名稱 主機名 root hostname 使用者名稱 主機名稱 符號含義 當前使用者屬於root使用者 當前使用者屬於普通使用者 注意 對系統進行配置管理時，如要root使用者 檢視主機名稱 hostname設定主機名稱 hostname hadoop senior.com注意 該方式設定，當...
spring 知識點梳理
1.spring預設所有管理的bean都是單例模式 懶載入，所有的bean都是交給spring容器中的map管理，生命週期與spring相同，如果使用多例模式，bean則是交給記憶體管理，生命週期與spring無關 2.ssm分層 控制層 服務層 資料層 對應的註解分別為 controller se...
Linux C知識點梳理
第1章 程式設計和c語言 最簡單的c語言程式 第2章 演算法 程式的靈魂 第3章 簡單的c程式設計 順序程式設計 常量，變數 先定義後使用 常變數，識別符號 資料型別 運算子與表示式，不同型別資料間混合運算 c語句 資料的輸入輸出，printf scanf 函式，字元資料輸入輸出 第4章 選擇結構程...