原文:Kafka API: TopicMetadata

Jusfr 原創,轉載請注明來自博客園 TopicMetadataRequest TopicMetadataResponse 前文簡單說過 Kafka是自描述的 ,是指其broker topic partition 信息可以通過 TopicMetadata API 獲取。 TopicMetadataRequest 的內容非常簡單,是一個包含 TopicName 的數組,TopicMetadata ...

2016-03-09 10:57 1 3433 推薦指數:

查看詳情

Kafka高級API和低級API

Kafka消費過程分析 kafka提供了兩套consumer API:高級Consumer API和低級API。 1 高級API 1)高級API優點 高級API 寫起來簡單 不需要去自行去管理offset,系統通過zookeeper自行管理 不需要管理分區,副本等情況,系統自動管理 ...

Wed May 22 18:43:00 CST 2019 0 1188
kafka api的基本使用

kafka API kafka Consumer提供兩套Java API:高級Consumer API、和低級Consumer API。 高級Consumer API 優點: 高級API寫起來簡單,易用。 不需要自行去管理offset,API已經封裝好了offset這塊的東西,會通 ...

Thu May 09 02:46:00 CST 2019 0 856
kafka connect rest api

1. 獲取 Connect Worker 信息curl -s http://127.0.0.1:8083/ | jq 2.列出 Connect Worker 上所有 Connector ...

Thu Apr 25 22:30:00 CST 2019 0 1492
Kafka高級API

目錄 1 Kafka高級API特性 1.1 Offset的自動控制 1.1.1 消費者offset初始策略 1.1.2 消費者offset自動提交策略 1.2 Acks & Retries(應答 ...

Wed Oct 21 03:38:00 CST 2020 1 489
kafka java API的使用

  Kafka包含四種核心的API:   1、Producer API支持應用將數據流發送到Kafka集群的主題   2、Consumer API支持應用從Kafka集群的主題中讀取數據流   3、Streams API支持數據流從輸入主題轉化到輸出主題   4、Connect API支持 ...

Fri Sep 14 23:14:00 CST 2018 0 4609
Kafka 消費者API

消費者api,自動提交offset 手動提交offset,同步提交 手動提交offset,異步提交 ...

Mon May 11 07:42:00 CST 2020 0 643
kafka sasl & java api

第一種 Properties props = new Properties(); props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, “node01 ...

Tue Jun 11 22:03:00 CST 2019 0 854
Kafka 核心 API ==> AdminClient

一、Kafka 核心 API   上文中對 Kafka 做了一些簡單的介紹,那么在開發過程中我們如何去訪問 Kafka 呢?這就需要使用到本文將要介紹的Kafka客戶端API。下圖是官方文檔中的一個圖,形象的描述了能與 Kafka集成的客戶端類型 Kafka的五類客戶端API類型 ...

Thu Aug 06 05:59:00 CST 2020 0 537
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM