關於Kafka producer管理TCP連接的討論
在Kafka中，TCP連接的管理交由底層的Selector類(org.apache.kafka.common.network)來維護。Selector類定義了很多數據結構，其中最核心的當屬java ...
花費 36 ms
關於Kafka冪等producer的討論
眾所周知，Kafka 0.11.0.0版本正式支持精確一次處理語義(exactly once semantics，下稱EOS)。Kafka的EOS主要體現在3個方面： 冪等producer ...
Kafka producer攔截器(interceptor)
Producer攔截器(interceptor)是個相當新的功能，它和consumer端interceptor是在Kafka 0.10版本被引入的，主要用於實現clients端的定制化控制邏輯。 ...
Kafka producer介紹
Kafka 0.9版本正式使用Java版本的producer替換了原Scala版本的producer。本文着重討論新版本producer的設計原理以及基本的使用方法。 新版本Producer 首先 ...
【譯】Kafka Producer Sticky Partitioner
最近事情多有點犯懶，依然帶來一篇譯文：Apache Kafka Producer Improvements with the Sticky Partitioner 消息在系統中流轉的時間對於Ka ...
kafka-producer kerberos 原理和配置
kerberos簡單介紹 kerberos這一名詞來源於希臘神話“三個頭的狗---地獄之門守護者”后來沿用作為安全認證的概念，該系統設計上 采用客戶端/服務器結構與DES(Data Encrypt ...