replace segmentio with Andrew-Zipperer

Andrew-Zipperer · Aug 21, 2021 · 6f54687 · 6f54687
1 parent 9fd2834
commit 6f54687
Show file tree

Hide file tree

Showing 100 changed files with 149 additions and 149 deletions.
diff --git a/README.md b/README.md
@@ -1,4 +1,4 @@
-# kafka-go [![CircleCI](https://circleci.com/gh/segmentio/kafka-go.svg?style=shield)](https://circleci.com/gh/segmentio/kafka-go) [![Go Report Card](https://goreportcard.com/badge/github.com/segmentio/kafka-go)](https://goreportcard.com/report/github.com/segmentio/kafka-go) [![GoDoc](https://godoc.org/github.com/segmentio/kafka-go?status.svg)](https://godoc.org/github.com/segmentio/kafka-go)
+# kafka-go [![CircleCI](https://circleci.com/gh/Andrew-Zipperer/kafka-go.svg?style=shield)](https://circleci.com/gh/segmentio/kafka-go) [![Go Report Card](https://goreportcard.com/badge/github.com/segmentio/kafka-go)](https://goreportcard.com/report/github.com/segmentio/kafka-go) [![GoDoc](https://godoc.org/github.com/segmentio/kafka-go?status.svg)](https://godoc.org/github.com/segmentio/kafka-go)
 
 ## Motivations
 
@@ -66,9 +66,9 @@ some features available from the Kafka API may not be implemented yet.
 
 ## Golang version
 
-`kafka-go` is currently compatible with golang version from 1.13+. To use with older versions of golang use release [v0.2.5](https://github.com/segmentio/kafka-go/releases/tag/v0.2.5).
+`kafka-go` is currently compatible with golang version from 1.13+. To use with older versions of golang use release [v0.2.5](https://github.com/Andrew-Zipperer/kafka-go/releases/tag/v0.2.5).
 
-## Connection [![GoDoc](https://godoc.org/github.com/segmentio/kafka-go?status.svg)](https://godoc.org/github.com/segmentio/kafka-go#Conn)
+## Connection [![GoDoc](https://godoc.org/github.com/Andrew-Zipperer/kafka-go?status.svg)](https://godoc.org/github.com/segmentio/kafka-go#Conn)
 
 The `Conn` type is the core of the `kafka-go` package. It wraps around a raw
 network connection to expose a low-level API to a Kafka server.
@@ -224,7 +224,7 @@ for k := range m {
 Because it is low level, the `Conn` type turns out to be a great building block
 for higher level abstractions, like the `Reader` for example.
 
-## Reader [![GoDoc](https://godoc.org/github.com/segmentio/kafka-go?status.svg)](https://godoc.org/github.com/segmentio/kafka-go#Reader)
+## Reader [![GoDoc](https://godoc.org/github.com/Andrew-Zipperer/kafka-go?status.svg)](https://godoc.org/github.com/segmentio/kafka-go#Reader)
 
 A `Reader` is another concept exposed by the `kafka-go` package, which intends
 to make it simpler to implement the typical use case of consuming from a single
@@ -342,7 +342,7 @@ r := kafka.NewReader(kafka.ReaderConfig{
 })
 ```
 
-## Writer [![GoDoc](https://godoc.org/github.com/segmentio/kafka-go?status.svg)](https://godoc.org/github.com/segmentio/kafka-go#Writer)
+## Writer [![GoDoc](https://godoc.org/github.com/Andrew-Zipperer/kafka-go?status.svg)](https://godoc.org/github.com/Andrew-Zipperer/kafka-go#Writer)
 
 To produce messages to Kafka, a program may use the low-level `Conn` API, but
 the package also provides a higher level `Writer` type which is more appropriate
@@ -549,15 +549,15 @@ You can specify an option on the `Dialer` to use SASL authentication. The `Diale
 
 ### SASL Authentication Types
 
-#### [Plain](https://godoc.org/github.com/segmentio/kafka-go/sasl/plain#Mechanism)
+#### [Plain](https://godoc.org/github.com/Andrew-Zipperer/kafka-go/sasl/plain#Mechanism)
 ```go
 mechanism := plain.Mechanism{
     Username: "username",
     Password: "password",
 }
 ```
 
-#### [SCRAM](https://godoc.org/github.com/segmentio/kafka-go/sasl/scram#Mechanism)
+#### [SCRAM](https://godoc.org/github.com/Andrew-Zipperer/kafka-go/sasl/scram#Mechanism)
 ```go
 mechanism, err := scram.Mechanism(scram.SHA512, "username", "password")
 if err != nil {

diff --git a/alterconfigs.go b/alterconfigs.go
@@ -6,7 +6,7 @@ import (
 	"net"
 	"time"
 
-	"github.com/segmentio/kafka-go/protocol/alterconfigs"
+	"github.com/Andrew-Zipperer/kafka-go/protocol/alterconfigs"
 )
 
 // AlterConfigsRequest represents a request sent to a kafka broker to alter configs

diff --git a/alterconfigs_test.go b/alterconfigs_test.go
@@ -4,7 +4,7 @@ import (
 	"context"
 	"testing"
 
-	ktesting "github.com/segmentio/kafka-go/testing"
+	ktesting "github.com/Andrew-Zipperer/kafka-go/testing"
 	"github.com/stretchr/testify/assert"
 )
 

diff --git a/alterpartitionreassignments.go b/alterpartitionreassignments.go
@@ -5,7 +5,7 @@ import (
 	"net"
 	"time"
 
-	"github.com/segmentio/kafka-go/protocol/alterpartitionreassignments"
+	"github.com/Andrew-Zipperer/kafka-go/protocol/alterpartitionreassignments"
 )
 
 // AlterPartitionReassignmentsRequest is a request to the AlterPartitionReassignments API.

diff --git a/alterpartitionreassignments_test.go b/alterpartitionreassignments_test.go
@@ -4,7 +4,7 @@ import (
 	"context"
 	"testing"
 
-	ktesting "github.com/segmentio/kafka-go/testing"
+	ktesting "github.com/Andrew-Zipperer/kafka-go/testing"
 )
 
 func TestClientAlterPartitionReassignments(t *testing.T) {

diff --git a/apiversions.go b/apiversions.go
@@ -4,8 +4,8 @@ import (
 	"context"
 	"net"
 
-	"github.com/segmentio/kafka-go/protocol"
-	"github.com/segmentio/kafka-go/protocol/apiversions"
+	"github.com/Andrew-Zipperer/kafka-go/protocol"
+	"github.com/Andrew-Zipperer/kafka-go/protocol/apiversions"
 )
 
 // ApiVersionsRequest is a request to the ApiVersions API.

diff --git a/client.go b/client.go
@@ -6,7 +6,7 @@ import (
 	"net"
 	"time"
 
-	"github.com/segmentio/kafka-go/protocol"
+	"github.com/Andrew-Zipperer/kafka-go/protocol"
 )
 
 const (

diff --git a/client_test.go b/client_test.go
@@ -9,8 +9,8 @@ import (
 	"testing"
 	"time"
 
-	"github.com/segmentio/kafka-go/compress"
-	ktesting "github.com/segmentio/kafka-go/testing"
+	"github.com/Andrew-Zipperer/kafka-go/compress"
+	ktesting "github.com/Andrew-Zipperer/kafka-go/testing"
 )
 
 func newLocalClientAndTopic() (*Client, string, func()) {

diff --git a/compress/compress.go b/compress/compress.go
@@ -3,10 +3,10 @@ package compress
 import (
 	"io"
 
-	"github.com/segmentio/kafka-go/compress/gzip"
-	"github.com/segmentio/kafka-go/compress/lz4"
-	"github.com/segmentio/kafka-go/compress/snappy"
-	"github.com/segmentio/kafka-go/compress/zstd"
+	"github.com/Andrew-Zipperer/kafka-go/compress/gzip"
+	"github.com/Andrew-Zipperer/kafka-go/compress/lz4"
+	"github.com/Andrew-Zipperer/kafka-go/compress/snappy"
+	"github.com/Andrew-Zipperer/kafka-go/compress/zstd"
 )
 
 // Compression represents the the compression applied to a record set.

diff --git a/compress/compress_test.go b/compress/compress_test.go
@@ -16,13 +16,13 @@ import (
 	"text/tabwriter"
 	"time"
 
-	"github.com/segmentio/kafka-go"
-	pkg "github.com/segmentio/kafka-go/compress"
-	"github.com/segmentio/kafka-go/compress/gzip"
-	"github.com/segmentio/kafka-go/compress/lz4"
-	"github.com/segmentio/kafka-go/compress/snappy"
-	"github.com/segmentio/kafka-go/compress/zstd"
-	ktesting "github.com/segmentio/kafka-go/testing"
+	"github.com/Andrew-Zipperer/kafka-go"
+	pkg "github.com/Andrew-Zipperer/kafka-go/compress"
+	"github.com/Andrew-Zipperer/kafka-go/compress/gzip"
+	"github.com/Andrew-Zipperer/kafka-go/compress/lz4"
+	"github.com/Andrew-Zipperer/kafka-go/compress/snappy"
+	"github.com/Andrew-Zipperer/kafka-go/compress/zstd"
+	ktesting "github.com/Andrew-Zipperer/kafka-go/testing"
 )
 
 func init() {

diff --git a/compression.go b/compression.go
@@ -3,7 +3,7 @@ package kafka
 import (
 	"errors"
 
-	"github.com/segmentio/kafka-go/compress"
+	"github.com/Andrew-Zipperer/kafka-go/compress"
 )
 
 type Compression = compress.Compression

diff --git a/conn.go b/conn.go
@@ -138,7 +138,7 @@ var (
 func init() {
 	progname := filepath.Base(os.Args[0])
 	hostname, _ := os.Hostname()
-	DefaultClientID = fmt.Sprintf("%s@%s (github.com/segmentio/kafka-go)", progname, hostname)
+	DefaultClientID = fmt.Sprintf("%s@%s (github.com/Andrew-Zipperer/kafka-go)", progname, hostname)
 }
 
 // NewConn returns a new kafka connection for the given topic and partition.

diff --git a/conn_test.go b/conn_test.go
@@ -12,7 +12,7 @@ import (
 	"testing"
 	"time"
 
-	ktesting "github.com/segmentio/kafka-go/testing"
+	ktesting "github.com/Andrew-Zipperer/kafka-go/testing"
 	"golang.org/x/net/nettest"
 )
 

diff --git a/createpartitions.go b/createpartitions.go
@@ -6,7 +6,7 @@ import (
 	"net"
 	"time"
 
-	"github.com/segmentio/kafka-go/protocol/createpartitions"
+	"github.com/Andrew-Zipperer/kafka-go/protocol/createpartitions"
 )
 
 // CreatePartitionsRequest represents a request sent to a kafka broker to create

diff --git a/createpartitions_test.go b/createpartitions_test.go
@@ -4,7 +4,7 @@ import (
 	"context"
 	"testing"
 
-	ktesting "github.com/segmentio/kafka-go/testing"
+	ktesting "github.com/Andrew-Zipperer/kafka-go/testing"
 )
 
 func TestClientCreatePartitions(t *testing.T) {

diff --git a/createtopics.go b/createtopics.go
@@ -7,7 +7,7 @@ import (
 	"net"
 	"time"
 
-	"github.com/segmentio/kafka-go/protocol/createtopics"
+	"github.com/Andrew-Zipperer/kafka-go/protocol/createtopics"
 )
 
 // CreateTopicRequests represents a request sent to a kafka broker to create

diff --git a/describeconfigs.go b/describeconfigs.go
@@ -6,7 +6,7 @@ import (
 	"net"
 	"time"
 
-	"github.com/segmentio/kafka-go/protocol/describeconfigs"
+	"github.com/Andrew-Zipperer/kafka-go/protocol/describeconfigs"
 )
 
 // DescribeConfigsRequest represents a request sent to a kafka broker to describe configs

diff --git a/describeconfigs_test.go b/describeconfigs_test.go
@@ -4,7 +4,7 @@ import (
 	"context"
 	"testing"
 
-	ktesting "github.com/segmentio/kafka-go/testing"
+	ktesting "github.com/Andrew-Zipperer/kafka-go/testing"
 	"github.com/stretchr/testify/assert"
 )
 

diff --git a/describegroups.go b/describegroups.go
@@ -7,7 +7,7 @@ import (
 	"fmt"
 	"net"
 
-	"github.com/segmentio/kafka-go/protocol/describegroups"
+	"github.com/Andrew-Zipperer/kafka-go/protocol/describegroups"
 )
 
 // DescribeGroupsRequest is a request to the DescribeGroups API.

diff --git a/dialer.go b/dialer.go
@@ -9,7 +9,7 @@ import (
 	"strings"
 	"time"
 
-	"github.com/segmentio/kafka-go/sasl"
+	"github.com/Andrew-Zipperer/kafka-go/sasl"
 )
 
 // The Dialer type mirrors the net.Dialer API but is designed to open kafka

diff --git a/electleaders.go b/electleaders.go
@@ -5,7 +5,7 @@ import (
 	"net"
 	"time"
 
-	"github.com/segmentio/kafka-go/protocol/electleaders"
+	"github.com/Andrew-Zipperer/kafka-go/protocol/electleaders"
 )
 
 // ElectLeadersRequest is a request to the ElectLeaders API.

diff --git a/electleaders_test.go b/electleaders_test.go
@@ -4,7 +4,7 @@ import (
 	"context"
 	"testing"
 
-	ktesting "github.com/segmentio/kafka-go/testing"
+	ktesting "github.com/Andrew-Zipperer/kafka-go/testing"
 )
 
 func TestClientElectLeaders(t *testing.T) {

diff --git a/example_consumergroup_test.go b/example_consumergroup_test.go
@@ -5,7 +5,7 @@ import (
 	"fmt"
 	"os"
 
-	"github.com/segmentio/kafka-go"
+	"github.com/Andrew-Zipperer/kafka-go"
 )
 
 func ExampleConsumerGroupParallelReaders() {

diff --git a/example_writer_test.go b/example_writer_test.go
@@ -3,7 +3,7 @@ package kafka_test
 import (
 	"context"
 
-	"github.com/segmentio/kafka-go"
+	"github.com/Andrew-Zipperer/kafka-go"
 )
 
 func ExampleWriter() {

diff --git a/examples/consumer-logger/go.mod b/examples/consumer-logger/go.mod
@@ -4,5 +4,5 @@ go 1.16
 
 require (
 	github.com/klauspost/compress v1.12.2 // indirect
-	github.com/segmentio/kafka-go v0.4.15
+	github.com/Andrew-Zipperer/kafka-go v0.4.15
 )
diff --git a/examples/consumer-logger/go.sum b/examples/consumer-logger/go.sum
@@ -21,8 +21,8 @@ github.com/pierrec/lz4 v2.6.0+incompatible h1:Ix9yFKn1nSPBLFl/yZknTp8TU5G4Ps0JDm
 github.com/pierrec/lz4 v2.6.0+incompatible/go.mod h1:pdkljMzZIN41W+lC3N2tnIh5sFi+IEE17M5jbnwPHcY=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/segmentio/kafka-go v0.4.15 h1:cEcaQX2cTenDH3LIMFfIQNzGxYWGNMp0LdWmYv89h64=
-github.com/segmentio/kafka-go v0.4.15/go.mod h1:19+Eg7KwrNKy/PFhiIthEPkO8k+ac7/ZYXwYM9Df10w=
+github.com/Andrew-Zipperer/kafka-go v0.4.15 h1:cEcaQX2cTenDH3LIMFfIQNzGxYWGNMp0LdWmYv89h64=
+github.com/Andrew-Zipperer/kafka-go v0.4.15/go.mod h1:19+Eg7KwrNKy/PFhiIthEPkO8k+ac7/ZYXwYM9Df10w=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/testify v1.6.1 h1:hDPOHmpOpP40lSULcqw7IrRb/u7w6RpDC9399XyoNd0=
 github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=

diff --git a/examples/consumer-logger/main.go b/examples/consumer-logger/main.go
@@ -7,7 +7,7 @@ import (
 	"os"
 	"strings"
 
-	kafka "github.com/segmentio/kafka-go"
+	kafka "github.com/Andrew-Zipperer/kafka-go"
 )
 
 func getKafkaReader(kafkaURL, topic, groupID string) *kafka.Reader {

diff --git a/examples/consumer-mongo-db/go.mod b/examples/consumer-mongo-db/go.mod
@@ -6,7 +6,7 @@ require (
 	github.com/go-stack/stack v1.8.0 // indirect
 	github.com/klauspost/compress v1.12.2 // indirect
 	github.com/mongodb/mongo-go-driver v0.3.0
-	github.com/segmentio/kafka-go v0.4.15
+	github.com/Andrew-Zipperer/kafka-go v0.4.15
 	github.com/tidwall/pretty v1.1.0 // indirect
 	golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4 // indirect
 )
diff --git a/examples/consumer-mongo-db/go.sum b/examples/consumer-mongo-db/go.sum
@@ -25,8 +25,8 @@ github.com/pierrec/lz4 v2.6.0+incompatible h1:Ix9yFKn1nSPBLFl/yZknTp8TU5G4Ps0JDm
 github.com/pierrec/lz4 v2.6.0+incompatible/go.mod h1:pdkljMzZIN41W+lC3N2tnIh5sFi+IEE17M5jbnwPHcY=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/segmentio/kafka-go v0.4.15 h1:cEcaQX2cTenDH3LIMFfIQNzGxYWGNMp0LdWmYv89h64=
-github.com/segmentio/kafka-go v0.4.15/go.mod h1:19+Eg7KwrNKy/PFhiIthEPkO8k+ac7/ZYXwYM9Df10w=
+github.com/Andrew-Zipperer/kafka-go v0.4.15 h1:cEcaQX2cTenDH3LIMFfIQNzGxYWGNMp0LdWmYv89h64=
+github.com/Andrew-Zipperer/kafka-go v0.4.15/go.mod h1:19+Eg7KwrNKy/PFhiIthEPkO8k+ac7/ZYXwYM9Df10w=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/testify v1.6.1 h1:hDPOHmpOpP40lSULcqw7IrRb/u7w6RpDC9399XyoNd0=
 github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=

diff --git a/examples/consumer-mongo-db/main.go b/examples/consumer-mongo-db/main.go
@@ -7,7 +7,7 @@ import (
 	"os"
 
 	"github.com/mongodb/mongo-go-driver/mongo"
-	kafka "github.com/segmentio/kafka-go"
+	kafka "github.com/Andrew-Zipperer/kafka-go"
 )
 
 func getMongoCollection(mongoURL, dbName, collectionName string) *mongo.Collection {

diff --git a/examples/producer-api/go.mod b/examples/producer-api/go.mod
@@ -4,5 +4,5 @@ go 1.15
 
 require (
 	github.com/klauspost/compress v1.12.2 // indirect
-	github.com/segmentio/kafka-go v0.4.15
+	github.com/Andrew-Zipperer/kafka-go v0.4.15
 )
diff --git a/examples/producer-api/go.sum b/examples/producer-api/go.sum
@@ -21,8 +21,8 @@ github.com/pierrec/lz4 v2.6.0+incompatible h1:Ix9yFKn1nSPBLFl/yZknTp8TU5G4Ps0JDm
 github.com/pierrec/lz4 v2.6.0+incompatible/go.mod h1:pdkljMzZIN41W+lC3N2tnIh5sFi+IEE17M5jbnwPHcY=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/segmentio/kafka-go v0.4.15 h1:cEcaQX2cTenDH3LIMFfIQNzGxYWGNMp0LdWmYv89h64=
-github.com/segmentio/kafka-go v0.4.15/go.mod h1:19+Eg7KwrNKy/PFhiIthEPkO8k+ac7/ZYXwYM9Df10w=
+github.com/Andrew-Zipperer/kafka-go v0.4.15 h1:cEcaQX2cTenDH3LIMFfIQNzGxYWGNMp0LdWmYv89h64=
+github.com/Andrew-Zipperer/kafka-go v0.4.15/go.mod h1:19+Eg7KwrNKy/PFhiIthEPkO8k+ac7/ZYXwYM9Df10w=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/testify v1.6.1 h1:hDPOHmpOpP40lSULcqw7IrRb/u7w6RpDC9399XyoNd0=
 github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=

diff --git a/examples/producer-api/main.go b/examples/producer-api/main.go
@@ -7,7 +7,7 @@ import (
 	"net/http"
 	"os"
 
-	kafka "github.com/segmentio/kafka-go"
+	kafka "github.com/Andrew-Zipperer/kafka-go"
 )
 
 func producerHandler(kafkaWriter *kafka.Writer) func(http.ResponseWriter, *http.Request) {

diff --git a/examples/producer-random/go.mod b/examples/producer-random/go.mod
@@ -6,5 +6,5 @@ require (
 	github.com/davecgh/go-spew v1.1.1 // indirect
 	github.com/google/uuid v1.1.0
 	github.com/klauspost/compress v1.12.2 // indirect
-	github.com/segmentio/kafka-go v0.4.15
+	github.com/Andrew-Zipperer/kafka-go v0.4.15
 )
diff --git a/examples/producer-random/go.sum b/examples/producer-random/go.sum
@@ -24,8 +24,8 @@ github.com/pierrec/lz4 v2.6.0+incompatible h1:Ix9yFKn1nSPBLFl/yZknTp8TU5G4Ps0JDm
 github.com/pierrec/lz4 v2.6.0+incompatible/go.mod h1:pdkljMzZIN41W+lC3N2tnIh5sFi+IEE17M5jbnwPHcY=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/segmentio/kafka-go v0.4.15 h1:cEcaQX2cTenDH3LIMFfIQNzGxYWGNMp0LdWmYv89h64=
-github.com/segmentio/kafka-go v0.4.15/go.mod h1:19+Eg7KwrNKy/PFhiIthEPkO8k+ac7/ZYXwYM9Df10w=
+github.com/Andrew-Zipperer/kafka-go v0.4.15 h1:cEcaQX2cTenDH3LIMFfIQNzGxYWGNMp0LdWmYv89h64=
+github.com/Andrew-Zipperer/kafka-go v0.4.15/go.mod h1:19+Eg7KwrNKy/PFhiIthEPkO8k+ac7/ZYXwYM9Df10w=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/testify v1.6.1 h1:hDPOHmpOpP40lSULcqw7IrRb/u7w6RpDC9399XyoNd0=
 github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=

diff --git a/examples/producer-random/main.go b/examples/producer-random/main.go
@@ -7,7 +7,7 @@ import (
 	"time"
 
 	"github.com/google/uuid"
-	kafka "github.com/segmentio/kafka-go"
+	kafka "github.com/Andrew-Zipperer/kafka-go"
 )
 
 func newKafkaWriter(kafkaURL, topic string) *kafka.Writer {
-Original file line number
+Diff line change
@@ Expand Up / @@ -6,7 +6,7 @@ import ( @@
     	"net"
     	"time"
-    	"github.com/segmentio/kafka-go/protocol/alterconfigs"
+    	"github.com/Andrew-Zipperer/kafka-go/protocol/alterconfigs"
     )
     // AlterConfigsRequest represents a request sent to a kafka broker to alter configs
@@ Expand Down @@