Chore: logging before produce

asheswook · asheswook · commit 11062667164d · 2024-07-24T14:32:28.000+09:00
diff --git a/internal/queue/kafka/operator.go b/internal/queue/kafka/operator.go
@@ -304,6 +304,8 @@ func (k *BytesProduceOperator) Produce(message []byte) error {
 		return errors.New("message is nil")
 	}
 
+	log.Print("Before Produce Message:" + string(k.topic))
+
 	_, _, err := producer.SendMessage(&sarama.ProducerMessage{
 		Topic: k.topic,
 		Value: sarama.ByteEncoder(message),

Original file line number	Diff line number	Diff line change
`@@ -304,6 +304,8 @@ func (k *BytesProduceOperator) Produce(message []byte) error {`
`304`	`304`	`return errors.New("message is nil")`
`305`	`305`	`}`
`306`	`306`
	`307`	`+ log.Print("Before Produce Message:" + string(k.topic))`
	`308`	`+`
`307`	`309`	`_, _, err := producer.SendMessage(&sarama.ProducerMessage{`
`308`	`310`	`Topic: k.topic,`
`309`	`311`	`Value: sarama.ByteEncoder(message),`