2.3 Streams API 官网剖析(博主推荐)

简介:

 一切来源于官网

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

 

 

 

 

 

 

 

 

2.3 Streams API

2.3 Streams API

 

 

在0.10.0增加了一个新的客户端库,Kafka Stream,Kafka Stream具有Alpha的优点,你可以使用maven引入到你的项目:

 

 

The Streams API allows transforming streams of data from input topics to output topics.

 

Examples showing how to use this library are given in the javadocs

 

Additional documentation on using the Streams API is available here.

 

To use Kafka Streams you can use the following maven dependency:

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




如何使用,请见如下。

KafkaStreams客户端(0.10.0.0 API)

http://orchome.com/305
 
  (注意, @InterfaceStability.Unstable注解的类,是公共API,在未来可能改变,不保证向后兼容)
 
 
 
 
 
 
 

使用Kafka Stream处理数据

http://orchome.com/300


本文转自大数据躺过的坑博客园博客,原文链接:http://www.cnblogs.com/zlslch/p/6768427.html,如需转载请自行联系原作者
相关文章
|
5月前
|
消息中间件 负载均衡 Kafka
一文读懂Kafka API:Producer、Consumer和Streams全解析
大家好,今天我们将深入探讨Kafka的三大核心API。通过这篇文章,你将了解如何使用Producer API发布记录流,利用Consumer API订阅和处理数据,以及通过Streams API实现复杂的流处理。一起开启Kafka的探索之旅吧!
181 2
|
6月前
|
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)
136 0
|
6月前
|
API Windows
解决echarts.apache.org官网不能访问的问题(主要是用于查看配置项API参数细节说明)
解决echarts.apache.org官网不能访问的问题(主要是用于查看配置项API参数细节说明)
|
SQL 存储 分布式计算
【Java新特性学习 四】JDK8: 库函数新特性之Optional,Streams,Date/Time API(JSR 310),Base64,并行数组
【Java新特性学习 四】JDK8: 库函数新特性之Optional,Streams,Date/Time API(JSR 310),Base64,并行数组
80 0
|
机器人 API Python
Python 技术篇-20行代码实现微信机器人斗图功能实例演示!斗图啦官网API调用方法
Python 技术篇-20行代码实现微信机器人斗图功能实例演示!斗图啦官网API调用方法
537 0
Python 技术篇-20行代码实现微信机器人斗图功能实例演示!斗图啦官网API调用方法
JDK11的新特性:HTTP API和reactive streams
JDK11的新特性:HTTP API和reactive streams
|
JSON API 网络安全
apigateway-kong(二)admin-api(结合实例比官网还详细)
部署好kong之后,则需要将我们自己的接口加入到kong中管理,kong提供了比较全面的restful api,每个版本会有所不同,下面的记录基于kong v0.13.x kong的8001端口是resful admin api,服务、路由、配置都是通过这个端口进行管理,所以部署好之后页面可以直接访问localhost:8001 下面针对每个模块的API进行简介,每个对象模块对应数据库中的一张存储表。
4075 0
下一篇
无影云桌面