Updated go packages

broker/kafka/kafka.go

@@ -2,7 +2,7 @@
 package kafka
 
 import (
-	"github.com/Shopify/sarama"
+	"github.com/IBM/sarama"
 
 	"github.com/pkritiotis/outbox"
 )

broker/kafka/kafka_test.go

@@ -3,7 +3,7 @@ package kafka
 import (
 	"testing"
 
-	"github.com/Shopify/sarama"
+	"github.com/IBM/sarama"
 	"github.com/pkritiotis/outbox"
 	"github.com/stretchr/testify/assert"
 )
@@ -22,9 +22,8 @@ func TestBroker_Send(t *testing.T) {
 					"MetadataRequest": sarama.NewMockMetadataResponse(t).
 						SetBroker(mp.Addr(), mp.BrokerID()).
 						SetLeader("sampleTopic", 0, mp.BrokerID()),
-					"ProduceRequest": sarama.NewMockProduceResponse(t),
+					"ProduceRequest": sarama.NewMockProduceResponse(t).SetError("sampleTopic", 0, sarama.ErrBrokerNotAvailable),
 				})
-
 				return mp
 			}(),
 			config: func() *sarama.Config {
@@ -44,7 +43,7 @@ func TestBroker_Send(t *testing.T) {
 				Body:  sarama.ByteEncoder("testing"),
 				Topic: "sampleTopic",
 			},
-			expErr: sarama.ErrInsufficientData,
+			expErr: sarama.KError(sarama.ErrBrokerNotAvailable),
 		},
 	}
 	for name, test := range tests {

examples/mySQL-Kafka/main.go

@@ -8,7 +8,7 @@ import (
 	"os"
 	"time"
 
-	"github.com/Shopify/sarama"
+	"github.com/IBM/sarama"
 	"github.com/pkritiotis/outbox"
 	"github.com/pkritiotis/outbox/broker/kafka"
 	"github.com/pkritiotis/outbox/store/mysql"

go.mod

@@ -3,30 +3,35 @@ module github.com/pkritiotis/outbox
 go 1.22
 
 require (
-	github.com/Shopify/sarama v1.31.0
-	github.com/go-sql-driver/mysql v1.6.0
-	github.com/google/uuid v1.3.0
-	github.com/stretchr/testify v1.7.0
+	github.com/IBM/sarama v1.43.2
+	github.com/go-sql-driver/mysql v1.8.1
+	github.com/google/uuid v1.6.0
+	github.com/stretchr/testify v1.9.0
 )
 
 require (
+	filippo.io/edwards25519 v1.1.0 // indirect
 	github.com/davecgh/go-spew v1.1.1 // indirect
-	github.com/eapache/go-resiliency v1.2.0 // indirect
-	github.com/eapache/go-xerial-snappy v0.0.0-20180814174437-776d5712da21 // indirect
+	github.com/eapache/go-resiliency v1.6.0 // indirect
+	github.com/eapache/go-xerial-snappy v0.0.0-20230731223053-c322873962e3 // indirect
 	github.com/eapache/queue v1.1.0 // indirect
 	github.com/golang/snappy v0.0.4 // indirect
-	github.com/hashicorp/go-uuid v1.0.2 // indirect
+	github.com/hashicorp/errwrap v1.1.0 // indirect
+	github.com/hashicorp/go-multierror v1.1.1 // indirect
+	github.com/hashicorp/go-uuid v1.0.3 // indirect
 	github.com/jcmturner/aescts/v2 v2.0.0 // indirect
 	github.com/jcmturner/dnsutils/v2 v2.0.0 // indirect
-	github.com/jcmturner/gofork v1.0.0 // indirect
-	github.com/jcmturner/gokrb5/v8 v8.4.2 // indirect
+	github.com/jcmturner/gofork v1.7.6 // indirect
+	github.com/jcmturner/gokrb5/v8 v8.4.4 // indirect
 	github.com/jcmturner/rpc/v2 v2.0.3 // indirect
-	github.com/klauspost/compress v1.13.6 // indirect
-	github.com/pierrec/lz4 v2.6.1+incompatible // indirect
+	github.com/klauspost/compress v1.17.8 // indirect
+	github.com/kr/text v0.2.0 // indirect
+	github.com/pierrec/lz4/v4 v4.1.21 // indirect
 	github.com/pmezard/go-difflib v1.0.0 // indirect
 	github.com/rcrowley/go-metrics v0.0.0-20201227073835-cf1acfcdf475 // indirect
-	github.com/stretchr/objx v0.1.0 // indirect
-	golang.org/x/crypto v0.0.0-20201112155050-0c6587e931a9 // indirect
-	golang.org/x/net v0.0.0-20220105145211-5b0dc2dfae98 // indirect
-	gopkg.in/yaml.v3 v3.0.0 // indirect
+	github.com/rogpeppe/go-internal v1.6.1 // indirect
+	github.com/stretchr/objx v0.5.2 // indirect
+	golang.org/x/crypto v0.22.0 // indirect
+	golang.org/x/net v0.24.0 // indirect
+	gopkg.in/yaml.v3 v3.0.1 // indirect
 )