1、由于我的预期目标是将filebeat收集的日志发送到kafka，所以配置output就选择了kafka。读者可根据自己的使用场景，配置output。例子中的配置将对/var/log目录下所有以.log结尾的文件进行采集。
让客户满意是我们工作的目标，不断超越客户的期望值来自于我们对这个行业的热爱。我们立志把好的技术通过有效、简单的方式提供给客户，将通过不懈努力成为客户在信息化领域值得信任、有价值的长期合作伙伴，公司提供的服务项目有：国际域名空间、网络空间、营销软件、网站建设、阳西网站维护、网站推广。
2、filebeat监听两个不同文件，配置了不同的topic。其中topic：%{[type]} ，topic值为input中配置的document_type。kafka中收集到日志如下格式：只有message中才为写入到，其余字段为filebeat携带的元数据。
3、使用filebeat收集日志，先转发到beat端的logstash1，然后logstash1转发到kafka，然后再由logstash2从kafka读取写到elasticsearch。
1、最好使用yaml struct标签创建显式映射。 我仅在示例中省略了它们，以说明未指定它们时的行为。将struct写入YAML文件：yaml.Marshal将interface {}作为参数。 可以传递任何Go值，并将其类型包装到interface {}中。
2、问题的关键在于GOPATH的设置，import是必须的，但是还有个条件就是要把自定义包的路径加入到GOPATH中。可以使用go env查看一下设置。 do it ~~~，开始可能会混乱，多试几次就好了。针对GO 的 2018年11月的最新版本。。
3、单击左窗格中的ToFile按钮，将出现一个窗口。设置新文件名和位置。选择YAML文件作为文件类型。添加并选择了一个绿色输出项。YAML文件会立即创建，无需“运行”任何内容您可以在右侧窗格中更改YAML文件编码。
4、让我们在GOPATH之外的首选位置为go项目创建文件夹 初始化模块 使用Go模块初始化项目名称。这将创建模块配置文件go.mod，其中包含模块名称和版本。
安装Consul后必须运行Agent，可以选择服务器或客户端模式。每个数据中心至少有一个服务器（推荐3~5个服务器集群）。
以Server模式运行的Consul Agent节点用于维护Consul集群的状态。官方建议每个Consul Cluster至少有 3个或以上的运行在Server Mode的Agent，Client节点不限 。
//localName表示元素的本地名称(不带前缀)；qName表示元素的限定名(带前缀)；attrs表示元素的属性集合。
