hailey.at / at-kafka
this repo has no description
fork atom

fix tap produce defer

hailey.at c55afb17 db5255dc

options
unified split
Changed files
+1 -1
atkafka
tap.go
+1 -1
atkafka/tap.go
··· 202 202 status := "ok" 203 203 ackStatus := "ok" 204 204 205 - go func() { 205 + defer func() { 206 206 producedEvents.WithLabelValues(status).Inc() 207 207 if s.ws != nil && !s.disableAcks { 208 208 acksSent.WithLabelValues(ackStatus).Inc()