简介
该用户还未填写简介
擅长的技术栈
可提供的服务
暂无可提供的服务
第一部分 Spring核心Spring提供了很多功能,但是所有这些功能的基础是是依赖注入(DI)和面向方面编程(AOP)。第一章 Springing into action本章包括:Spring的bean容器探索Spring的核心模块强大的Spring生态系统Spring的新特性现在是java程序员的好时代。在长达20年的发展过程中,java经历了一
kafka初见(Meet Kafka)在讨论Kafka细节之前,有必要先来了解下消息发布/订阅的概念,这个概念非常重要。 kafka中的数据单位是message。对比数据库来说,可以把消息看做数据库中的记录。对kafka而言,一个消息就是一个字节数组,字节数组中的数据没有特定的格式或者意义。消息有一个可选的元数据信息,称为key。key也是一个字节数组,与消息一样,没有特别的含义。ke
上图所示,consumer订阅kafka集群中(一个broker中的一个topic中)的消息,然后对broker发起一个获取消息的请求,请求中携带了topic、partition、offset等信息,接着用pull的方式获取kafka log中所有可用消息,并对消息中的数据进行处理,比如使用spark进行计算,将结果存入DB中。consumer订阅消息时,会连接上任一个可用的broker,并获
第三章kafka producer---向kafka写入消息无论你将kafka作为一个消息队列,或者消息总线,还是一个数据存储平台,你都要通过生产者producer向kafka写入数据,通过消费者consumer读取kafka的数据。例如,一个信用卡事务处理系统,会有一个客户端应用或者一个在线商店应用,负责在交易发生时,将每一个事务发送到kafka,另一个应用通过规则引擎校验这个事务,决定