Skip to content

E
enoch
Commit 40835266 authored by Node- 门 忠鑫's avatar Node- 门 忠鑫
Browse files
Options

# 修改group名称

parent f4608fa0
Show whitespace changes
Inline Side-by-side
Showing with 3 additions and 3 deletions
service/conf/kafka_conf.go
View file @ 40835266
...@@ -11,12 +11,12 @@ func HealthTopic() KafkaConf { ...@@ -11,12 +11,12 @@ func HealthTopic() KafkaConf {
return KafkaConf{ return KafkaConf{
GlobalConfig.Kafka.Brokers, GlobalConfig.Kafka.Brokers,
"quantGroup.tech.enoch.pro", "quantGroup.tech.enoch.pro",
"quantGroup-enoch-agent"} "quantGroup-enoch-agent-pro"}
} }
func BraveTopic() KafkaConf { func BraveTopic() KafkaConf {
return KafkaConf{ return KafkaConf{
GlobalConfig.Kafka.Brokers, GlobalConfig.Kafka.Brokers,
"quantGroup.tech.brave.pro", "quantGroup.tech.brave.pro",
"enoch-group"} "enoch-group-pro"}
} }
service/msg_process.go
View file @ 40835266
...@@ -66,7 +66,7 @@ func msgInfluxProcess(traceMsgs []TraceMsg) { ...@@ -66,7 +66,7 @@ func msgInfluxProcess(traceMsgs []TraceMsg) {
} }
unix := time.Unix(0, traceMsg.Timestamp*1000) unix := time.Unix(0, traceMsg.Timestamp*1000)
fmt.Println(traceMsg.Timestamp)
if len(pointSlice) == batchSize { if len(pointSlice) == batchSize {
go batchWrite(pointSlice) go batchWrite(pointSlice)
pointSlice = make([]*client.Point, 0, batchSize) pointSlice = make([]*client.Point, 0, batchSize)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment