一个项目完整的生命周期是从开发的coding阶段和coding阶段的质量测试，再到多次发布投入使用。目前大部分的测试阶段并不是从coding结束后开始的，而是和coding同步进行的。可能今天早上coding完成一个功能，下午就要投入测试。在这期间，我们可能会因为需求发生变化功能需要改进缺陷需要修复等问题要更新服务。这个过程是重复而且是复杂的，也容易出现部署、更新失误的情况。因此我们有了自动构建的

docker-compose.ymlversion: "3.0"services:zookeeper:image: wurstmeister/zookeepercontainer_name: zookeeperrestart: alwaysports:- 2181:2181kafka:image: wurstmeister/kafkacontainer_name: kafkaports:- 90

背景需要将redis 某个/类频道推送的数据写入到kafka topic中。实现一、编写kafka source connector代码和配置文件我这里是在github上找了一个别人已经实现了的kafka-redis-connector，选取了source的部分。git地址。连接器配置文件xx.properties介绍：name=定义连接器名字connector.class=连接器的类名（例如：c

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

前景最近在编写了一个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