简介SpringCloud任务允许用户使用SpringCloud开发和运行短期的微服务，在本地 、云环境中、甚至在SpringCloud Data Flow上运行它们。仅添加注解@EnableTask便可将app作为spring boot app运行。spring cloud task让创建短期的微服务变得很容易。它提供的功能允许在生产环境中按需执行短期的JVM进程。环境要求Java8级...

0、背景总所周知，SPI在很多地方都有着很好的实践，比如JDBC驱动的加载、dubbo等，SpringBoot项目的autoConfiguration也是类似的原理。这里就感觉用来做模块解耦也不错。比如我们做应用管理的一个服务，它具有应用安装、升级、扩容等功能，经常在安装、升级、扩容流程中应用要求做一些定制化的东西，比如安装数据库，需要初始化database；安装kafka，需要初始化topic；

1、KafkaListenerspring-kafka确实很方便，在方法上加@KafkaListener便实现对kafka数据的接收。从KafkaListener这个注解的各个参数注释上我们可以看出，各个参数不仅可以配置直接的值，也可以配置SPEL表达式，还是比较灵活的。2、topic配置的几种方式（1）直接设置为字符常量，不再赘述（2）application.properties中配置topic

1、idea中开发kafka并发测试需要的扩展包由于jmeter的jms模块并不支持kafka，因此需要扩展开发引入jmeter<dependency><groupId>org.apache.jmeter</groupId><artifactId>ApacheJMeter_core</artifactId><version>5

0.背景kafka的服务端和客户端之间使用IP连接，服务端也未配置任何域名，但是却出现了一个奇怪的问题。kafka客户端达到一定数量的时候，大量的连接在超时，服务端出现了许多CLOSE_WAIT状态的连接，抓包发现服务端有时候关闭完一个连接需要花费几分钟的时间，超出了客户端设置的超时时间，客户端在不断重连，服务端的CLOSE_WAIT越来越多。表现出来的问题表象就是客户端连接超时，连kafka集群

0.背景虽然大部分的java项目使用的都是logback，但是仍然有很多开源项目使用log4j，例如kafka、zookeeper。但是log4j已经于2012年停止更新，并且log4j扫出如下安全漏洞：https://rnd-vulncenter.huawei.com/vuln/toViewOfficialDetail?cveId=CVE-2020-9488https://rnd-vulncen