We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent fc051c1 commit bf908eeCopy full SHA for bf908ee
router-tests/testenv/pubsub.go
@@ -52,17 +52,20 @@ func setupKafkaServer(t testing.TB) (*KafkaData, error) {
52
defer kafkaMux.Unlock()
53
54
kafkaRefs += 1
55
+ t.Logf("Adds kafka: %d", kafkaRefs)
56
57
t.Cleanup(func() {
58
kafkaMux.Lock()
59
60
61
if kafkaRefs > 1 {
62
kafkaRefs -= 1
63
+ t.Logf("Removes kafka: %d", kafkaRefs)
64
} else {
65
if err := kafkaContainer.Close(); err != nil {
66
t.Fatalf("could not purge kafka container: %s", err.Error())
67
}
68
+ t.Logf("Cleans kafka: %d", kafkaRefs)
69
// This shouldn't be needed, but just in case
70
kafkaData = nil
71
kafkaContainer = nil
0 commit comments