pkg/sink: remove useless comment

risingwavelabs · May 15, 2023 · e47e068 · e47e068
1 parent b101bcf
commit e47e068
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/pkg/sink/kafka.go b/pkg/sink/kafka.go
@@ -89,6 +89,5 @@ func (k *KafkaSink) Flush(ctx context.Context) error {
 
 func (k *KafkaSink) Close(ctx context.Context) error {
 	k.producer.Flush(10 * 1000)
-	//k.producer.Close()
 	return nil
 }