Skip to content
This repository was archived by the owner on Aug 23, 2023. It is now read-only.

Commit 579cf25

Browse files
committed
roll back changes that shouldn't be in this PR
1 parent ef8e98f commit 579cf25

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

publish/kafka/publish.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -279,12 +279,12 @@ func (m *mtPublisher) Publish(metrics []*schema.MetricData) error {
279279
if m.autoInterval {
280280
_, s := m.schemas.Match(metric.Name, 0)
281281
metric.Interval = s.Retentions.Rets[0].SecondsPerPoint
282+
metric.SetId()
282283
} else {
283284
log.Error("interval is 0 but can't deduce interval automatically. this should never happen")
284285
return errors.New("need to deduce interval but cannot")
285286
}
286287
}
287-
metric.SetId()
288288

289289
isMD := false
290290
isMP := false

0 commit comments

Comments
 (0)