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)