From 4eecb06e2c44a2dab219da603f2596e6cccf7189 Mon Sep 17 00:00:00 2001 From: Vasiliy Tolstov Date: Tue, 22 Sep 2020 14:43:15 +0300 Subject: [PATCH] cleanup Signed-off-by: Vasiliy Tolstov --- segmentio.go | 3 --- 1 file changed, 3 deletions(-) diff --git a/segmentio.go b/segmentio.go index f6f1a13..fb249e0 100644 --- a/segmentio.go +++ b/segmentio.go @@ -4,7 +4,6 @@ package segmentio import ( "context" "errors" - "fmt" "sync" "time" @@ -187,10 +186,8 @@ func (k *kBroker) Publish(topic string, msg *broker.Message, opts ...broker.Publ buf, err := k.opts.Codec.Marshal(msg) if err != nil { - fmt.Printf("TTTT %v\n", err) return err } - fmt.Printf("FFFF\n") kmsg := kafka.Message{Value: buf} k.Lock()