Fix typo

Author: asheswook

internal/consumer.go

@@ -219,7 +219,7 @@ func (consumer *StreamConsumer) Transaction(producer sarama.AsyncProducer, messa
 	if err != nil {
 		fmt.Println("Error committing transaction:", err)
 		consumer.handleTxnError(producer, message, session, err, func() error {
-			return producer.AddMessageToTxn(message, consumer.groupId, nil)
+			return producer.CommitTxn()
 		})
 		return
 	}

internal/consumer_test.go

@@ -11,7 +11,7 @@ import (
 	"time"
 )
 
-var cbrokers = []string{"localhost:9093"}
+var cbrokers = []string{"kafka.vp-datacenter-1.violetpay.net:9092", "kafka.vp-datacenter-1.violetpay.net:9093", "kafka.vp-datacenter-1.violetpay.net:9094"}
 
 // TestSerializer is a mock implementation of common.MessageSerializer
 type TestSerializer struct {

internal/producer_test.go

@@ -8,7 +8,7 @@ import (
 	"testing"
 )
 
-var pbrokers = []string{"localhost:9093"}
+var pbrokers = []string{"kafka.vp-datacenter-1.violetpay.net:9092", "kafka.vp-datacenter-1.violetpay.net:9093", "kafka.vp-datacenter-1.violetpay.net:9094"}
 
 func TestNewProducerPool(t *testing.T) {
 	t.Run("NewProducerPool no configProvider", func(t *testing.T) {