2.2 Consumer API官网剖析(博主推荐)

简介:

一切来源于官网

http://kafka.apache.org/documentation/

 

 

 

 

 

2.2 Consumer API

2.2、消费者API

 

 

随着0.9.0版本,我们已经增加了一个新的Java消费者替换我们现有的基于zookeeper的高级和低级消费者。
这个客户端还是测试版的质量。为了确保用户平滑升级,
我们仍然维护旧的0.8版本的消费者客户端继续在0.9集群上工作,
两个老的0.8 API的消费者( 高级消费者 和 低级消费者)。

 

 

The Consumer API allows applications to read streams of data from topics in the Kafka cluster.

 

Examples showing how to use the consumer are given in the javadocs.

 

 

To use the consumer, you can use the following maven dependency:

 对于使用生产者,你可以使用以下的maven依赖
		<dependency>
			<groupId>org.apache.kafka</groupId>
			<artifactId>kafka-clients</artifactId>
			<version>0.10.2.0</version>
		</dependency>
	






如何使用新的消费者,请请见如下

kafka消费者客户端(0.10.0.1API)

http://orchome.com/451

 


 
 
 

kafka消费者客户端(0.9.0.1API)

http://orchome.com/203

 

 
 
 

kafka消费者低级实例

http://orchome.com/11

 

 

 

kafka旧高级消费者API

http://orchome.com/9


本文转自大数据躺过的坑博客园博客,原文链接:http://www.cnblogs.com/zlslch/p/6767693.html,如需转载请自行联系原作者
相关文章
|
8月前
|
消息中间件 Kafka API
kafka Consumer high-level api 之白名单
kafka Consumer high-level api 之白名单
|
7月前
|
消息中间件 负载均衡 Kafka
一文读懂Kafka API:Producer、Consumer和Streams全解析
大家好,今天我们将深入探讨Kafka的三大核心API。通过这篇文章,你将了解如何使用Producer API发布记录流,利用Consumer API订阅和处理数据,以及通过Streams API实现复杂的流处理。一起开启Kafka的探索之旅吧!
239 2
|
8月前
|
API Python
记录openai官网关于Setup your API key for a single project(为单个项目设置API 可以)的错误(2023/11/24)
记录openai官网关于Setup your API key for a single project(为单个项目设置API 可以)的错误(2023/11/24)
172 0
|
8月前
|
消息中间件 缓存 Java
Kafka Consumer java api 配置
Kafka Consumer java api 配置
|
8月前
|
API Windows
解决echarts.apache.org官网不能访问的问题(主要是用于查看配置项API参数细节说明)
解决echarts.apache.org官网不能访问的问题(主要是用于查看配置项API参数细节说明)
|
消息中间件 分布式计算 Java
Spark Streaming实时流处理项目实战笔记——Kafka Consumer Java API编程
Spark Streaming实时流处理项目实战笔记——Kafka Consumer Java API编程
|
机器人 API Python
Python 技术篇-20行代码实现微信机器人斗图功能实例演示!斗图啦官网API调用方法
Python 技术篇-20行代码实现微信机器人斗图功能实例演示!斗图啦官网API调用方法
546 0
Python 技术篇-20行代码实现微信机器人斗图功能实例演示!斗图啦官网API调用方法
|
消息中间件 运维 Kafka
kafka API consumer
kafka API consumer1.kafka consumer流程1.1.在启动时或者协调节点故障转移时,消费者发送ConsumerMetadataRequest给bootstrap brokers列表中的任意一个brokers。
1120 0
|
JSON API 网络安全
apigateway-kong(二)admin-api(结合实例比官网还详细)
部署好kong之后,则需要将我们自己的接口加入到kong中管理,kong提供了比较全面的restful api,每个版本会有所不同,下面的记录基于kong v0.13.x kong的8001端口是resful admin api,服务、路由、配置都是通过这个端口进行管理,所以部署好之后页面可以直接访问localhost:8001 下面针对每个模块的API进行简介,每个对象模块对应数据库中的一张存储表。
4090 0