Comment decommission of the producer

signalfx · Oct 1, 2021 · ba6c12c · ba6c12c
1 parent b16090f
commit ba6c12c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...mentation/github.com/confluentinc/confluent-kafka-go/kafka/splunkkafka/test/kafka_test.go b/...mentation/github.com/confluentinc/confluent-kafka-go/kafka/splunkkafka/test/kafka_test.go
@@ -189,6 +189,7 @@ func TestChannelBasedProducer(t *testing.T) {
 			break
 		}
 	}
+	// Decommission the producer, ensure it is not used anymore.
 	p.Close()
 
 	recv := consumeMessage(t, kafka.TopicPartition{
@@ -234,6 +235,7 @@ func TestFunctionBasedProducer(t *testing.T) {
 			break
 		}
 	}
+	// Decommission the producer, ensure it is not used anymore.
 	p.Close()
 
 	recv := consumeMessage(t, kafka.TopicPartition{