From 26a450d2cbc3a2e93d3329cbe7baa27726aa30f0 Mon Sep 17 00:00:00 2001 From: varnit goyal Date: Thu, 19 Dec 2024 15:39:07 +0530 Subject: [PATCH] TP-5555 | service log limit --- pkg/kafka/producer/produce.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/kafka/producer/produce.go b/pkg/kafka/producer/produce.go index a529898..b545cd7 100644 --- a/pkg/kafka/producer/produce.go +++ b/pkg/kafka/producer/produce.go @@ -60,10 +60,10 @@ func (kp *KProducerImpl) PublishEvent(msgPayload interface{}, topic, key string, log.Log.Info("failed to deliver message:", zap.Int32("topic partition", message.TopicPartition.Partition)) } else { - log.Log.Info("delivered to topic at offset", - zap.String("topic", *message.TopicPartition.Topic), - zap.Int32("partition", message.TopicPartition.Partition), - zap.String("offset", message.TopicPartition.Offset.String())) + //log.Log.Info("delivered to topic at offset", + // zap.String("topic", *message.TopicPartition.Topic), + // zap.Int32("partition", message.TopicPartition.Partition), + // zap.String("offset", message.TopicPartition.Offset.String())) } close(deliveryChan)