Skip to content

Commit e931feb

Browse files
committed
removed code leftover from debug logging
1 parent 9a3af5d commit e931feb

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

http-gateway/cmd/http-gateway.go

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -94,9 +94,6 @@ func replyHandler(producer sarama.AsyncProducer, replies *repliesMap) http.Handl
9494
}
9595
kafkaMsg.Topic = topic
9696

97-
encoded, _ := kafkaMsg.Value.Encode()
98-
decoded, _ := wireformat.FromKafka(&sarama.ConsumerMessage{Value:encoded})
99-
10097
select {
10198
case producer.Input() <- kafkaMsg:
10299
select {

0 commit comments

Comments
 (0)