2019-07-13
前面我们在k8s上部署了一个kafka集群,同时也部署了kafka-manager对kafka集群进行监控管理。
本篇将先基于spring boot框架编写一个简单的kafka的生产者和消费者的程序,并在此基础上理解kafka的相关组件。
1.使用Spring Boot开发Kafka的Producer和Consumer
#
从https://start.spring.io/创建一个名称为kafka-demo
的spring boot工程,这里基于的是Spring Boot 2.1.6,依赖中选择添加Spring for Apache Kafka
。项目创建完毕后,首先需要在spring boot的配置文件application.yml
通过配置spring.kafka.bootstrap-servers
指定kafka代理地址。
...2019-02-04
Spring Boot Gradle Plugin简介
#
Spring Boot Gradle Plugin提供了Gradle构建工具对Spring Boot的支持,使用它不仅可以完成Spring Boot项目的打包(executable jar or distribution tar)、运行,还可以使用spring-boot-dependencies
提供的依赖管理功能。
...2019-02-03
Lombok其实和Spring Boot关系不太大,只是这个工具太好用了,这里也整理记录一下。
Lombok是一个Java库可以与Java IDE(ItelliJ IDEA、Eclipse)和构建工具(Gradle、Maven)集成,帮助开发人员消除臃肿的Java代码,尤其是对于Java POJO类,使用Lombok后将不再需要我们去编写getter、setter、equals、hashcode等方案,Lombok通过注解实现这一目标。
...2019-02-02
Spring Boot 2.x中使用HikariCP作为默认的数据连接池。
HikariCP使用Javassist字节码操作库来实现动态代理,优化并精简了字节码,同时内部使用com.zaxxer.hikari.util.FastList
代替ArrayList、使用了更好的并发集合类com.zaxxer.hikari.util.ConcurrentBag
,“号称”是目前最快的数据库连接池。
...