今天就跟大家聊聊有關(guān)Java中的Kafka 怎么利用API進行調(diào)用，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

創(chuàng)新互聯(lián)為客戶提供專業(yè)的成都網(wǎng)站設(shè)計、成都做網(wǎng)站、程序、域名、空間一條龍服務(wù)，提供基于WEB的系統(tǒng)開發(fā). 服務(wù)項目涵蓋了網(wǎng)頁設(shè)計、網(wǎng)站程序開發(fā)、WEB系統(tǒng)開發(fā)、微信二次開發(fā)、手機網(wǎng)站開發(fā)等網(wǎng)站方面業(yè)務(wù)。

1.客戶端創(chuàng)建對應(yīng)協(xié)議的請求

2.客戶端發(fā)送請求給對應(yīng)的broker

3.broker處理請求，并發(fā)送response給客戶端

雖然Kafka提供的大量的腳本工具用于各種功能的實現(xiàn)，但很多時候我們還是希望可以把某些功能以編程的方式嵌入到另一個系統(tǒng)中。這時使用Java API的方式就顯得異常地靈活了。本文我將嘗試給出Java API底層框架的一個范例，同時也會針對“創(chuàng)建topic”和“查看位移”這兩個主要功能給出對應(yīng)的例子。 需要提前說明的是，本文給出的范例并沒有考慮Kafka集群開啟安全的情況。另外Kafka的KIP4應(yīng)該一直在優(yōu)化命令行工具以及各種管理操作，有興趣的讀者可以關(guān)注這個KIP。

本文中用到的API依賴于kafka-clients，所以如果你使用Maven構(gòu)建的話，請加上：

  org.apache.kafka
  kafka-clients
  0.10.2.0

網(wǎng)站欄目：Java中的Kafka怎么利用API進行調(diào)用-創(chuàng)新互聯(lián)
URL地址：http://weahome.cn/article/djjjgd.html