官术网_书友最值得收藏!

第2章 生產者

從編程的角度而言,生產者就是負責向Kafka發送消息的應用程序。在Kafka的歷史變遷中,一共有兩個大版本的生產者客戶端:第一個是于Kafka開源之初使用Scala語言編寫的客戶端,我們可以稱之為舊生產者客戶端(Old Producer)或Scala版生產者客戶端;第二個是從Kafka 0.9.x 版本開始推出的使用 Java 語言編寫的客戶端,我們可以稱之為新生產者客戶端(New Producer)或Java版生產者客戶端,它彌補了舊版客戶端中存在的諸多設計缺陷。

雖然Kafka是用Java/Scala語言編寫的,但這并不妨礙它對于多語言的支持,在Kafka官網中,“CLIENTS”的入口[1]提供了一份多語言的支持列表,其中包括常用的C/C++、Python、Go等語言,不過這些其他類語言的客戶端并非由Kafka社區維護,如果使用則需要另行下載。本章主要針對現下流行的新生產者(Java語言編寫的)客戶端做詳細介紹,而舊生產者客戶端已被淘汰,故不再做相應的介紹了。

主站蜘蛛池模板: 内江市| 额敏县| 大兴区| 黄梅县| 灵台县| 原平市| 夹江县| 高碑店市| 资兴市| 尼勒克县| 开远市| 丰都县| 三明市| 兴业县| 永吉县| 儋州市| 天气| 南平市| 隆化县| 十堰市| 英山县| 镇沅| 洪江市| 锡林郭勒盟| 共和县| 建昌县| 金塔县| 若尔盖县| 太保市| 汝州市| 灵武市| 泽普县| 东兴市| 禄丰县| 获嘉县| 重庆市| 柯坪县| 南开区| 翁牛特旗| 北票市| 衡水市|