zzm219 / rocketmq-beat-output Goto Github PK

mkdir -p $GOPATH/src/github.com/kukuzidian/
cd $GOPATH/src/github.com/kukuzidian/
git clone https://github.com/kukuzidian/rocketmq-beat-output
cd rocketmq-beat-output

package main

import (
    "os"
    _ "github.com/kukuzidian/rocketmq-beat-output/rocketmq"
    "github.com/elastic/beats/x-pack/filebeat/cmd"
)

func main() {
    if err := cmd.RootCmd.Execute(); err != nil {
        os.Exit(1)
    }
}

go build -o filebeat main.go

output.rocketmq:
  namesrvaddr: "172.16.14.128:9876"
  topic: "beat_topic"
  groupName: "filebeatProducer"
  producename: "producename"
  tag: "A1"
  enabled: true
  codec.json:
    pretty: false
    escape_html: false

./filebeat modules enable system
./filebeat modules list
./filebeat -c filebeat.yml -e

go build -o metricbeat metricbeat.go
go build -o filebeat filebeat.go
go build -o functionbeat functionbeat.go
go build -o journalbeat journalbeat.go
go build -o auditbeat auditbeat.go
go build -o winlogbeat winlogbeat.go
go build -o packetbeat packetbeat.go