原文: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