ETCD迁移

线上版本etcd Version: 3.4.4Git SHA: c65a9e2ddGo Version: go1.12.12Go OS/Arch: linux/amd640x01 方案一： 加入原有集群进行数据同步如果集群使用了证书，同步之前需要先使用etcdctl同步新证书，在进行相关操作1、查看

Kafka常用命令

记录开发过程中用kafka进行测试常用的命令1 启动kafka 以Mac为例源码安装的情况下（brew安装可以以服务的方式管理）先进入kafka安装目录下的bin目录先启动zookeeperzookeeper-server-start /usr/local/etc/kafka/zookeeper.

logstash org.jruby.exceptions.SystemExit: (SystemExit) exit 错误

通过yum install logstash， 使用sudo systemctl start logstash时， logstash的日志/var/log/logstash/logstash-plain.log出现如下错误[2022-03-02T16:27:48,993][INFO ][logsta

移除go编译后panic的路径信息

正常情况下我们使用go build编译一个项目后，如果程序在运行过程中出现了panic，那么堆栈信息中就会包含开发环境的路径信息，如下这样不安全和不严谨。报错信息里包含了你编译时候项目的所在路径在golang1.13之后可以直接使用选项trimpath移除路径信息go build -trimpath

golang HTTP 连接未被释放的问题

Flink快速上手

[toc]0x01 Flink特点支持Scala和Java API支持批流一体同时支持高吞吐、低延迟和高性能支持事件时间和处理时间语义，基于事件时间语义能够针对无序事件提供精确、一致的结果，基于处理时间语义能够用在具有极低延迟需求的应用中支持不同时间语义下的窗口调整支持有状态计算支持具有Backpr