kafka模块

kafka监控

redis缓存

复用连接 --- 多个线程复用AdminClient

加锁

spi

jmx -- 多个端口

热启动 -- 自动化

kafka消费

线程池多线程消费 --- future

幂等处理 -- redis缓存

hash计算多个分区

ack = 1

顺序消费

流量分析项目

SPI
策略模式
责任链模式