varnitgoyal95/cybertron
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

TP-5555 | service log limit

Browse Source
This commit is contained in:
varnit goyal
2024-12-19 15:39:07 +05:30
parent 5b00be9b48
commit 26a450d2cb
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/kafka/producer/produce.go
View File

@@ -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)