Compare commits
2 Commits
3ba8ba4a22
...
cca1240a65
Author | SHA1 | Date | |
---|---|---|---|
cca1240a65 | |||
7ad495fe2b |
@ -196,8 +196,8 @@ func (k *Kafka) NewWriter(topic string) (*kafka.Writer, error) {
|
||||
Topic: topic,
|
||||
Balancer: &kafka.LeastBytes{},
|
||||
BatchSize: 2000,
|
||||
Compression: kafka.Snappy,
|
||||
Logger: k.l,
|
||||
Compression: kafka.Lz4,
|
||||
// Logger: k.l,
|
||||
ErrorLogger: k.l,
|
||||
}
|
||||
|
||||
|
@ -84,10 +84,11 @@ func RegisterMetric(registry prometheus.Registerer) {
|
||||
Name: "build_info",
|
||||
Help: "Build information",
|
||||
},
|
||||
[]string{"version"},
|
||||
[]string{"version", "build"},
|
||||
)
|
||||
registry.MustRegister(buildInfo)
|
||||
buildInfo.WithLabelValues(Version()).Set(1)
|
||||
info := VersionInfo()
|
||||
buildInfo.WithLabelValues(fmt.Sprintf("%s/%s", info.Version, info.GitRev), info.BuildTime).Set(1)
|
||||
}
|
||||
|
||||
var v string
|
||||
|
Loading…
x
Reference in New Issue
Block a user