前景最近在编写了一个websocket+kafka的推送订阅组件，类似之前的一篇wesocket+redis的推送订阅组件。在实现完功能后，发现一个问题就是从websocket接收到订阅信息到websocket推送接收到的kafka数据这期间花了3s多，排查了一个，这3s用在了这里：也就是Request joining group due to: need to re-join with the

原理websocket的订阅就是在前后端建立ws连接之后，前端通过发送一定格式的消息，后端解析出来去订阅或者取消订阅redis频道。订阅频道消息格式:{"cmd":"subscribe","topic":["topic_name"]}取消订阅格式{"cmd":"unsubscribe","topic":["topic_name"]}两个核心类，一个是redis的订阅监听类，一个是websock

背景平时我们在用docker-compose更新服务的时候，当我们敲下docker-compose up -d service回车之后到服务成功启动起来之前的这段时间，该service是不会提供服务的。这还是建立在服务正常启动的情况下，如果服务没有正常启动，那该service停止服务的时间会更长。有没有一种可以在更新的时候不打扰原本服务的运行，在更新结束后替换调原本的服务呢？思路命令行输入dock

前言本意利用kafka实现一个类似redis发布订阅的模式，比redis多了一个数据分区的功能。kafka里面的数据我们是不需要存储的，因此我们需要配置对应的删除策略Kafka版本号2.8.1数据清理策略kafka有两种数据清理策略，delete删除和compact压缩，默认是删除。delete：一般是使用按照时间保留的策略，当不活跃的segment的时间戳是大于设置的时间的时候，当前segmen