一次golang sarama kafka内存占用大的排查经历

环境：

创新互联公司成都网站建设按需网站制作，是成都网站维护公司,为成都高空作业车租赁提供网站建设服务,有成熟的网站定制合作流程，提供网站定制设计服务：原型图制作、网站创意设计、前端HTML5制作、后台程序开发等。成都网站改版热线：028-86922220

现象：golang微服务内存占用超过1G，查看日志发现大量kafka相关错误日志，继而查看kafka集群，其中一个kafka节点容器挂掉了。

疑问 为什么kafka集群只有一个broker挂了，客户端就大量报错呢

通过beego admin页面获取 mem-1.memprof

可以看到调用栈为 withRecover backgroundMetadataUpdataer refreshMeaatdata RefreshMetada tryRefreshMetadata ...

sarama-cluster: NewClient

为什么kafka集群只有一个broker，但是NewClient确失败了？

在kafka容器里查看topic, 发现Replicas和Isr只有一个，找到kafka官方配置说明，自动生成的topic需要配置default.replication.factor这个参数，才会生成3副本。

golang 怎样控制自己实现log的位置

log是日志文件可以用记事本，直接打开查看内容，具体方法为：

1、Log文件上右键，然后选择【打开方式】--再选择【记事本】，如下图所示。

2、之后我们就可以查看到Log文件内容了，如下示意图所示。

有时候时间记事本打开某些Log文件里面全是乱码又或者Log文件太大，比如超过100M，那么使用Windows自带的记事本就无法打开此类Log文件，需要借助一些更为专业的Log文件查看器。具体步骤如下：

1、首先下载LogViewPro工具。

2、下载后解压文件，然后直接运行名为“LogViewPro”应用程序文件即可打开软件即可。

3、接下来我们再从顶部左侧的【文件】菜单选择【打开】。

4、最后通过浏览，找到电脑中的Log文件，将其打开即可。

Go语言基础语法（一）

本文介绍一些Go语言的基础语法。

先来看一个简单的go语言代码：

go语言的注释方法：

代码执行结果：

下面来进一步介绍go的基础语法。

go语言中格式化输出可以使用 fmt 和 log 这两个标准库，

常用方法：

示例代码：

执行结果：

更多格式化方法可以访问中的fmt包。

log包实现了简单的日志服务，也提供了一些格式化输出的方法。

执行结果：

下面来介绍一下go的数据类型

下表列出了go语言的数据类型：

int、float、bool、string、数组和struct属于值类型，这些类型的变量直接指向存在内存中的值；slice、map、chan、pointer等是引用类型，存储的是一个地址，这个地址存储最终的值。

常量是在程序编译时就确定下来的值，程序运行时无法改变。

执行结果：

执行结果：

Go 语言的运算符主要包括算术运算符、关系运算符、逻辑运算符、位运算符、赋值运算符以及指针相关运算符。

算术运算符：

关系运算符：

逻辑运算符：

位运算符：

赋值运算符：

指针相关运算符：

下面介绍一下go语言中的if语句和switch语句。另外还有一种控制语句叫select语句，通常与通道联用，这里不做介绍。

if语法格式如下：

if ... else ：

else if：

示例代码：

语法格式：

另外，添加 fallthrough 会强制执行后面的 case 语句，不管下一条case语句是否为true。

示例代码：

执行结果：

下面介绍几种循环语句：

执行结果：

执行结果：

也可以通过标记退出循环：

--THE END--

Go语言之log（如何将日志写到指定文件里面）

对于Go语言的日志来说，如何将log写到指定的文件里面，下面是一个例子。

output:

output: