chore: some fixes

Trendyol · Mar 28, 2024 · bc8ff85 · bc8ff85
1 parent 48986ac
commit bc8ff85
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 4 deletions.
diff --git a/batch_consumer.go b/batch_consumer.go
@@ -179,7 +179,6 @@ func (b *batchConsumer) process(chunkMessages []*Message) {
 			errorMessage := consumeErr.Error()
 			if b.transactionalRetry {
 				for i := range chunkMessages {
-					chunkMessages[i].ErrDescription = consumeErr.Error()
 					cronsumerMessages = append(cronsumerMessages, chunkMessages[i].toRetryableMessage(b.retryTopic, errorMessage))
 				}
 			} else {

diff --git a/examples/with-kafka-transactional-retry-disabled/main.go b/examples/with-kafka-transactional-retry-disabled/main.go
@@ -12,8 +12,7 @@ import (
 
 func main() {
 	producer, _ := kafka.NewProducer(&kafka.ProducerConfig{
-		DistributedTracingConfiguration: kafka.DistributedTracingConfiguration{},
-		Writer:                          kafka.WriterConfig{Brokers: []string{"localhost:29092"}, Topic: "standart-topic"},
+		Writer: kafka.WriterConfig{Brokers: []string{"localhost:29092"}, Topic: "standart-topic"},
 	})
 
 	producer.ProduceBatch(context.Background(), []kafka.Message{

diff --git a/message.go b/message.go
@@ -31,7 +31,7 @@ type Message struct {
 
 	// IsFailed Is only used on transactional retry disabled
 	IsFailed bool
-	// ErrDescription specifies IsFailed message error
+	// ErrDescription specifies the IsFailed message's error
 	ErrDescription string
 }