diff --git a/.github/ISSUE_TEMPLATE/bug_report.md b/.github/ISSUE_TEMPLATE/bug_report.md index 99d907bbf..30a68282a 100644 --- a/.github/ISSUE_TEMPLATE/bug_report.md +++ b/.github/ISSUE_TEMPLATE/bug_report.md @@ -36,7 +36,7 @@ assignees: '' package main import ( - "github.com/segmentio/kafka-go" + "github.com/generalmotors/kafka-go" ) func main() { diff --git a/addoffsetstotxn.go b/addoffsetstotxn.go index dd83edb3a..6fe0332da 100644 --- a/addoffsetstotxn.go +++ b/addoffsetstotxn.go @@ -6,7 +6,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/addoffsetstotxn" + "github.com/generalmotors/kafka-go/protocol/addoffsetstotxn" ) // AddOffsetsToTxnRequest is the request structure for the AddOffsetsToTxn function. diff --git a/addoffsetstotxn_test.go b/addoffsetstotxn_test.go index 56d6ee46a..8a539c8bf 100644 --- a/addoffsetstotxn_test.go +++ b/addoffsetstotxn_test.go @@ -9,7 +9,7 @@ import ( "testing" "time" - ktesting "github.com/segmentio/kafka-go/testing" + ktesting "github.com/generalmotors/kafka-go/testing" ) func TestClientAddOffsetsToTxn(t *testing.T) { diff --git a/addpartitionstotxn.go b/addpartitionstotxn.go index 74792135e..c2d1990c1 100644 --- a/addpartitionstotxn.go +++ b/addpartitionstotxn.go @@ -6,7 +6,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/addpartitionstotxn" + "github.com/generalmotors/kafka-go/protocol/addpartitionstotxn" ) // AddPartitionToTxn represents a partition to be added diff --git a/addpartitionstotxn_test.go b/addpartitionstotxn_test.go index 7e7efe8e5..49f877ad7 100644 --- a/addpartitionstotxn_test.go +++ b/addpartitionstotxn_test.go @@ -7,7 +7,7 @@ import ( "testing" "time" - ktesting "github.com/segmentio/kafka-go/testing" + ktesting "github.com/generalmotors/kafka-go/testing" ) func TestClientAddPartitionsToTxn(t *testing.T) { diff --git a/alterclientquotas.go b/alterclientquotas.go index 7a926e5c4..2de812dd5 100644 --- a/alterclientquotas.go +++ b/alterclientquotas.go @@ -6,7 +6,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/alterclientquotas" + "github.com/generalmotors/kafka-go/protocol/alterclientquotas" ) // AlterClientQuotasRequest represents a request sent to a kafka broker to diff --git a/alterclientquotas_test.go b/alterclientquotas_test.go index d61c745e3..9e6cca2f2 100644 --- a/alterclientquotas_test.go +++ b/alterclientquotas_test.go @@ -4,7 +4,7 @@ import ( "context" "testing" - ktesting "github.com/segmentio/kafka-go/testing" + ktesting "github.com/generalmotors/kafka-go/testing" "github.com/stretchr/testify/assert" ) diff --git a/alterconfigs.go b/alterconfigs.go index c994506a1..98e384d8a 100644 --- a/alterconfigs.go +++ b/alterconfigs.go @@ -6,7 +6,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/alterconfigs" + "github.com/generalmotors/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 index f36dac18d..0fb851642 100644 --- 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/generalmotors/kafka-go/testing" "github.com/stretchr/testify/assert" ) diff --git a/alterpartitionreassignments.go b/alterpartitionreassignments.go index dd67d003b..d2fc3c0b9 100644 --- a/alterpartitionreassignments.go +++ b/alterpartitionreassignments.go @@ -5,7 +5,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/alterpartitionreassignments" + "github.com/generalmotors/kafka-go/protocol/alterpartitionreassignments" ) // AlterPartitionReassignmentsRequest is a request to the AlterPartitionReassignments API. diff --git a/alterpartitionreassignments_test.go b/alterpartitionreassignments_test.go index 7bbce8fff..b9019671b 100644 --- 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/generalmotors/kafka-go/testing" ) func TestClientAlterPartitionReassignments(t *testing.T) { diff --git a/alteruserscramcredentials.go b/alteruserscramcredentials.go index 6163e564e..5b9a0c522 100644 --- a/alteruserscramcredentials.go +++ b/alteruserscramcredentials.go @@ -6,7 +6,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/alteruserscramcredentials" + "github.com/generalmotors/kafka-go/protocol/alteruserscramcredentials" ) // AlterUserScramCredentialsRequest represents a request sent to a kafka broker to diff --git a/alteruserscramcredentials_test.go b/alteruserscramcredentials_test.go index f980dfd11..e80f0e937 100644 --- a/alteruserscramcredentials_test.go +++ b/alteruserscramcredentials_test.go @@ -4,7 +4,7 @@ import ( "context" "testing" - ktesting "github.com/segmentio/kafka-go/testing" + ktesting "github.com/generalmotors/kafka-go/testing" ) func TestAlterUserScramCredentials(t *testing.T) { diff --git a/apiversions.go b/apiversions.go index 52412b811..420ac3183 100644 --- 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/generalmotors/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol/apiversions" ) // ApiVersionsRequest is a request to the ApiVersions API. diff --git a/builder_test.go b/builder_test.go index 07775662e..41a894de3 100644 --- a/builder_test.go +++ b/builder_test.go @@ -6,7 +6,7 @@ import ( "io" "time" - "github.com/segmentio/kafka-go/compress" + "github.com/generalmotors/kafka-go/compress" ) // This file defines builders to assist in creating kafka payloads for unit testing. diff --git a/client.go b/client.go index d965040e8..a23cde5a1 100644 --- a/client.go +++ b/client.go @@ -7,7 +7,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol" ) const ( diff --git a/client_test.go b/client_test.go index 62153b234..60c6d019a 100644 --- a/client_test.go +++ b/client_test.go @@ -10,8 +10,8 @@ import ( "testing" "time" - "github.com/segmentio/kafka-go/compress" - ktesting "github.com/segmentio/kafka-go/testing" + "github.com/generalmotors/kafka-go/compress" + ktesting "github.com/generalmotors/kafka-go/testing" ) func newLocalClientAndTopic() (*Client, string, func()) { diff --git a/compress/compress.go b/compress/compress.go index 054bf03d0..22c14f589 100644 --- a/compress/compress.go +++ b/compress/compress.go @@ -7,10 +7,10 @@ import ( "strconv" "strings" - "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/generalmotors/kafka-go/compress/gzip" + "github.com/generalmotors/kafka-go/compress/lz4" + "github.com/generalmotors/kafka-go/compress/snappy" + "github.com/generalmotors/kafka-go/compress/zstd" ) // Compression represents the compression applied to a record set. diff --git a/compress/compress_test.go b/compress/compress_test.go index 1da841227..03bd9a648 100644 --- a/compress/compress_test.go +++ b/compress/compress_test.go @@ -15,14 +15,14 @@ import ( "text/tabwriter" "time" + "github.com/generalmotors/kafka-go" + pkg "github.com/generalmotors/kafka-go/compress" + "github.com/generalmotors/kafka-go/compress/gzip" + "github.com/generalmotors/kafka-go/compress/lz4" + "github.com/generalmotors/kafka-go/compress/snappy" + "github.com/generalmotors/kafka-go/compress/zstd" + ktesting "github.com/generalmotors/kafka-go/testing" gz "github.com/klauspost/compress/gzip" - "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" ) func init() { diff --git a/compress/snappy/xerial_test.go b/compress/snappy/xerial_test.go index 72d3b5c8a..740d1ff7a 100644 --- a/compress/snappy/xerial_test.go +++ b/compress/snappy/xerial_test.go @@ -6,8 +6,8 @@ import ( "io" "testing" + goxerialsnappy "github.com/generalmotors/kafka-go/compress/snappy/go-xerial-snappy" "github.com/klauspost/compress/snappy" - goxerialsnappy "github.com/segmentio/kafka-go/compress/snappy/go-xerial-snappy" ) // Wrap an io.Reader or io.Writer to disable all copy optimizations like diff --git a/compression.go b/compression.go index 411fe87a1..f233a9552 100644 --- a/compression.go +++ b/compression.go @@ -3,7 +3,7 @@ package kafka import ( "errors" - "github.com/segmentio/kafka-go/compress" + "github.com/generalmotors/kafka-go/compress" ) type Compression = compress.Compression diff --git a/conn_test.go b/conn_test.go index bdce327e0..accd8f5b8 100644 --- a/conn_test.go +++ b/conn_test.go @@ -13,7 +13,7 @@ import ( "testing" "time" - ktesting "github.com/segmentio/kafka-go/testing" + ktesting "github.com/generalmotors/kafka-go/testing" "golang.org/x/net/nettest" ) diff --git a/createacls.go b/createacls.go index 601974171..0f2214ebc 100644 --- a/createacls.go +++ b/createacls.go @@ -7,7 +7,7 @@ import ( "strings" "time" - "github.com/segmentio/kafka-go/protocol/createacls" + "github.com/generalmotors/kafka-go/protocol/createacls" ) // CreateACLsRequest represents a request sent to a kafka broker to add diff --git a/createacls_test.go b/createacls_test.go index 314427a57..80a6a794f 100644 --- a/createacls_test.go +++ b/createacls_test.go @@ -4,7 +4,7 @@ import ( "context" "testing" - ktesting "github.com/segmentio/kafka-go/testing" + ktesting "github.com/generalmotors/kafka-go/testing" ) func TestClientCreateACLs(t *testing.T) { diff --git a/createpartitions.go b/createpartitions.go index d4c0d0e70..c40435c65 100644 --- a/createpartitions.go +++ b/createpartitions.go @@ -6,7 +6,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/createpartitions" + "github.com/generalmotors/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 index 8ab847d0e..9722042d7 100644 --- 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/generalmotors/kafka-go/testing" ) func TestClientCreatePartitions(t *testing.T) { diff --git a/createtopics.go b/createtopics.go index 8ad9ebf44..2bc1a72e6 100644 --- a/createtopics.go +++ b/createtopics.go @@ -7,7 +7,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/createtopics" + "github.com/generalmotors/kafka-go/protocol/createtopics" ) // CreateTopicRequests represents a request sent to a kafka broker to create diff --git a/deleteacls.go b/deleteacls.go index 64cbd26d1..0a3ddf713 100644 --- a/deleteacls.go +++ b/deleteacls.go @@ -6,7 +6,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/deleteacls" + "github.com/generalmotors/kafka-go/protocol/deleteacls" ) // DeleteACLsRequest represents a request sent to a kafka broker to delete diff --git a/deleteacls_test.go b/deleteacls_test.go index 299cede22..b52a39c4b 100644 --- a/deleteacls_test.go +++ b/deleteacls_test.go @@ -4,7 +4,7 @@ import ( "context" "testing" - ktesting "github.com/segmentio/kafka-go/testing" + ktesting "github.com/generalmotors/kafka-go/testing" "github.com/stretchr/testify/assert" ) diff --git a/deletegroups.go b/deletegroups.go index 6317ae7fa..2dcb46216 100644 --- a/deletegroups.go +++ b/deletegroups.go @@ -6,7 +6,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/deletegroups" + "github.com/generalmotors/kafka-go/protocol/deletegroups" ) // DeleteGroupsRequest represents a request sent to a kafka broker to delete diff --git a/deletegroups_test.go b/deletegroups_test.go index e857ac435..aab734f91 100644 --- a/deletegroups_test.go +++ b/deletegroups_test.go @@ -6,7 +6,7 @@ import ( "testing" "time" - ktesting "github.com/segmentio/kafka-go/testing" + ktesting "github.com/generalmotors/kafka-go/testing" ) func TestClientDeleteGroups(t *testing.T) { diff --git a/deletetopics.go b/deletetopics.go index d758d9fd6..43d572fce 100644 --- a/deletetopics.go +++ b/deletetopics.go @@ -7,7 +7,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/deletetopics" + "github.com/generalmotors/kafka-go/protocol/deletetopics" ) // DeleteTopicsRequest represents a request sent to a kafka broker to delete diff --git a/describeacls.go b/describeacls.go index d1093bbed..d1f2f1922 100644 --- a/describeacls.go +++ b/describeacls.go @@ -6,7 +6,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/describeacls" + "github.com/generalmotors/kafka-go/protocol/describeacls" ) // DescribeACLsRequest represents a request sent to a kafka broker to describe diff --git a/describeacls_test.go b/describeacls_test.go index 25585b25c..8c7645fa7 100644 --- a/describeacls_test.go +++ b/describeacls_test.go @@ -4,7 +4,7 @@ import ( "context" "testing" - ktesting "github.com/segmentio/kafka-go/testing" + ktesting "github.com/generalmotors/kafka-go/testing" "github.com/stretchr/testify/assert" ) diff --git a/describeclientquotas.go b/describeclientquotas.go index 6291dcd98..431c52ec8 100644 --- a/describeclientquotas.go +++ b/describeclientquotas.go @@ -6,7 +6,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/describeclientquotas" + "github.com/generalmotors/kafka-go/protocol/describeclientquotas" ) // DescribeClientQuotasRequest represents a request sent to a kafka broker to diff --git a/describeconfigs.go b/describeconfigs.go index 17f4f305f..4ce4687d3 100644 --- a/describeconfigs.go +++ b/describeconfigs.go @@ -6,7 +6,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/describeconfigs" + "github.com/generalmotors/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 index 60b0db7ff..d88815256 100644 --- 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/generalmotors/kafka-go/testing" "github.com/stretchr/testify/assert" ) diff --git a/describegroups.go b/describegroups.go index 4faf7a01b..9010f01c1 100644 --- a/describegroups.go +++ b/describegroups.go @@ -7,7 +7,7 @@ import ( "fmt" "net" - "github.com/segmentio/kafka-go/protocol/describegroups" + "github.com/generalmotors/kafka-go/protocol/describegroups" ) // DescribeGroupsRequest is a request to the DescribeGroups API. diff --git a/describeuserscramcredentials.go b/describeuserscramcredentials.go index 7194ea1e0..e8751900e 100644 --- a/describeuserscramcredentials.go +++ b/describeuserscramcredentials.go @@ -6,7 +6,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/describeuserscramcredentials" + "github.com/generalmotors/kafka-go/protocol/describeuserscramcredentials" ) // DescribeUserScramCredentialsRequest represents a request sent to a kafka broker to diff --git a/describeuserscramcredentials_test.go b/describeuserscramcredentials_test.go index d30b47477..9be90f94b 100644 --- a/describeuserscramcredentials_test.go +++ b/describeuserscramcredentials_test.go @@ -5,7 +5,7 @@ import ( "errors" "testing" - ktesting "github.com/segmentio/kafka-go/testing" + ktesting "github.com/generalmotors/kafka-go/testing" "github.com/stretchr/testify/assert" ) diff --git a/dialer.go b/dialer.go index 7786ed320..dbeed742a 100644 --- a/dialer.go +++ b/dialer.go @@ -11,7 +11,7 @@ import ( "strings" "time" - "github.com/segmentio/kafka-go/sasl" + "github.com/generalmotors/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 index 2dd63b73d..6009bf495 100644 --- a/electleaders.go +++ b/electleaders.go @@ -5,7 +5,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/electleaders" + "github.com/generalmotors/kafka-go/protocol/electleaders" ) // ElectLeadersRequest is a request to the ElectLeaders API. diff --git a/electleaders_test.go b/electleaders_test.go index 3dbaa4704..d89edccd5 100644 --- 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/generalmotors/kafka-go/testing" ) func TestClientElectLeaders(t *testing.T) { diff --git a/endtxn.go b/endtxn.go index ebfeab2ee..e2b692cef 100644 --- a/endtxn.go +++ b/endtxn.go @@ -6,7 +6,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/endtxn" + "github.com/generalmotors/kafka-go/protocol/endtxn" ) // EndTxnRequest represets a request sent to a kafka broker to end a transaction. diff --git a/example_consumergroup_test.go b/example_consumergroup_test.go index b1dc9097f..3835cc7fb 100644 --- a/example_consumergroup_test.go +++ b/example_consumergroup_test.go @@ -6,7 +6,7 @@ import ( "fmt" "os" - "github.com/segmentio/kafka-go" + "github.com/generalmotors/kafka-go" ) func ExampleGeneration_Start_consumerGroupParallelReaders() { diff --git a/example_writer_test.go b/example_writer_test.go index 398b553b4..fac16d581 100644 --- 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/generalmotors/kafka-go" ) func ExampleWriter() { diff --git a/examples/consumer-logger/main.go b/examples/consumer-logger/main.go index ff4f97d6d..4c9e3905b 100644 --- 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/generalmotors/kafka-go" ) func getKafkaReader(kafkaURL, topic, groupID string) *kafka.Reader { diff --git a/examples/consumer-mongo-db/main.go b/examples/consumer-mongo-db/main.go index 3ad144f3f..28a1d717d 100644 --- a/examples/consumer-mongo-db/main.go +++ b/examples/consumer-mongo-db/main.go @@ -6,8 +6,8 @@ import ( "log" "os" + kafka "github.com/generalmotors/kafka-go" "github.com/mongodb/mongo-go-driver/mongo" - kafka "github.com/segmentio/kafka-go" ) func getMongoCollection(mongoURL, dbName, collectionName string) *mongo.Collection { diff --git a/examples/producer-api/main.go b/examples/producer-api/main.go index ba365f6ea..5989561cd 100644 --- 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/generalmotors/kafka-go" ) func producerHandler(kafkaWriter *kafka.Writer) func(http.ResponseWriter, *http.Request) { diff --git a/examples/producer-random/main.go b/examples/producer-random/main.go index 10cf314ea..2a302f8c5 100644 --- a/examples/producer-random/main.go +++ b/examples/producer-random/main.go @@ -6,8 +6,8 @@ import ( "os" "time" + kafka "github.com/generalmotors/kafka-go" "github.com/google/uuid" - kafka "github.com/segmentio/kafka-go" ) func newKafkaWriter(kafkaURL, topic string) *kafka.Writer { diff --git a/fetch.go b/fetch.go index eafd0de88..36ea2a5f8 100644 --- a/fetch.go +++ b/fetch.go @@ -7,8 +7,8 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol" - fetchAPI "github.com/segmentio/kafka-go/protocol/fetch" + "github.com/generalmotors/kafka-go/protocol" + fetchAPI "github.com/generalmotors/kafka-go/protocol/fetch" ) // FetchRequest represents a request sent to a kafka broker to retrieve records diff --git a/fetch_test.go b/fetch_test.go index 270b429a3..f6076312e 100644 --- a/fetch_test.go +++ b/fetch_test.go @@ -10,7 +10,7 @@ import ( "testing" "time" - "github.com/segmentio/kafka-go/compress" + "github.com/generalmotors/kafka-go/compress" ) func produceRecords(t *testing.T, n int, addr net.Addr, topic string, compression compress.Codec) []Record { diff --git a/findcoordinator.go b/findcoordinator.go index cbf07153d..b54161115 100644 --- a/findcoordinator.go +++ b/findcoordinator.go @@ -7,7 +7,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/findcoordinator" + "github.com/generalmotors/kafka-go/protocol/findcoordinator" ) // CoordinatorKeyType is used to specify the type of coordinator to look for. diff --git a/go.mod b/go.mod index 484c3f549..2cc7d0b12 100644 --- a/go.mod +++ b/go.mod @@ -4,11 +4,13 @@ go 1.15 require ( github.com/klauspost/compress v1.15.9 + github.com/kr/pretty v0.3.1 // indirect github.com/pierrec/lz4/v4 v4.1.15 - github.com/segmentio/kafka-go v0.4.47 - github.com/stretchr/testify v1.8.0 + github.com/rogpeppe/go-internal v1.12.0 // indirect + github.com/stretchr/testify v1.9.0 github.com/xdg-go/scram v1.1.2 - golang.org/x/net v0.17.0 + golang.org/x/net v0.28.0 + gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c // indirect ) retract [v0.4.36, v0.4.37] diff --git a/go.sum b/go.sum index 390579503..6b73b3a9e 100644 --- a/go.sum +++ b/go.sum @@ -1,19 +1,34 @@ +github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E= github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY= github.com/klauspost/compress v1.15.9 h1:wKRjX6JRtDdrE9qwa4b/Cip7ACOshUI4smpCQanqjSY= github.com/klauspost/compress v1.15.9/go.mod h1:PhcZ0MbTNciWF3rruxRgKxI5NkcHHrHUDtV4Yw2GlzU= +github.com/kr/pretty v0.2.1/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI= +github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE= +github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk= +github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ= +github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI= +github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY= +github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= github.com/pierrec/lz4/v4 v4.1.15 h1:MO0/ucJhngq7299dKLwIMtgTfbkoSPF6AoMYDd8Q4q0= github.com/pierrec/lz4/v4 v4.1.15/go.mod h1:gZWDp/Ze/IJXGXf23ltt2EXimqmTUXEy0GFuRQyBid4= +github.com/pkg/diff v0.0.0-20210226163009-20ebb0f2a09e/go.mod h1:pJLUxLENpZxwdsKMEsNbx1VGcRFpLqf3715MtcvvzbA= 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.47 h1:IqziR4pA3vrZq7YdRxaT3w1/5fvIH5qpCwstUanQQB0= -github.com/segmentio/kafka-go v0.4.47/go.mod h1:HjF6XbOKh0Pjlkr5GVZxt6CsjjwnmhVOfURM5KMd8qg= +github.com/rogpeppe/go-internal v1.9.0/go.mod h1:WtVeX8xhTBvf0smdhujwtBcq4Qrzq/fJaraNFVN+nFs= +github.com/rogpeppe/go-internal v1.12.0 h1:exVL4IDcn6na9z1rAb56Vxr+CgyK3nn3O+epU5NdKM8= +github.com/rogpeppe/go-internal v1.12.0/go.mod h1:E+RYuTGaKKdloAfM02xzb0FW3Paa99yedzYV+kq4uf4= github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw= +github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo= +github.com/stretchr/objx v0.5.2/go.mod h1:FRsXN1f5AsAjCGJKqEizvkpNtU+EGNCLh3NxZ/8L+MA= github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= -github.com/stretchr/testify v1.8.0 h1:pSgiaMZlXftHpm5L7V1+rVB+AZJydKsMxsQBIJw4PKk= github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU= +github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo= +github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg= +github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY= github.com/xdg-go/pbkdf2 v1.0.0 h1:Su7DPu48wXMwC3bs7MCNG+z4FhcyEuz5dlvchbq0B0c= github.com/xdg-go/pbkdf2 v1.0.0/go.mod h1:jrpuAogTd400dnrH08LKmI/xc1MbPOebTwRqcT5RDeI= github.com/xdg-go/scram v1.1.2 h1:FHX5I5B4i4hKRVRBCFRxq1iQRej7WO3hhBuJf+UUySY= @@ -23,19 +38,33 @@ github.com/xdg-go/stringprep v1.0.4/go.mod h1:mPGuuIYwz7CmR2bT9j4GbQqutWS1zV24gi github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY= golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc= -golang.org/x/crypto v0.14.0/go.mod h1:MVFd36DqK4CsrnJYDkBA3VC4m2GkXAM0PvzMCn4JQf4= +golang.org/x/crypto v0.13.0/go.mod h1:y6Z2r+Rw4iayiXXAIxJIDAJ1zMW4yaTpebo8fPOliYc= +golang.org/x/crypto v0.19.0/go.mod h1:Iy9bg/ha4yyC70EfRS8jz+B6ybOBKMaSxLj6P6oBDfU= +golang.org/x/crypto v0.23.0/go.mod h1:CKFgDieR+mRhux2Lsu27y0fO304Db0wZe70UKqHu0v8= +golang.org/x/crypto v0.26.0/go.mod h1:GY7jblb9wI+FOo5y8/S2oY4zWP07AkOJ4+jxCqdqn54= golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4= golang.org/x/mod v0.8.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs= +golang.org/x/mod v0.9.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs= +golang.org/x/mod v0.12.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs= +golang.org/x/mod v0.15.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c= +golang.org/x/mod v0.17.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c= golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg= golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c= golang.org/x/net v0.6.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs= golang.org/x/net v0.10.0/go.mod h1:0qNGK6F8kojg2nk9dLZ2mShWaEBan6FAoqfSigmmuDg= -golang.org/x/net v0.17.0 h1:pVaXccu2ozPjCXewfr1S7xza/zcXTity9cCdXQYSjIM= -golang.org/x/net v0.17.0/go.mod h1:NxSsAGuq816PNPmqtQdLE42eU2Fs7NoRIZrHJAlaCOE= +golang.org/x/net v0.15.0/go.mod h1:idbUs1IY1+zTqbi8yxTbhexhEEk5ur9LInksu6HrEpk= +golang.org/x/net v0.21.0/go.mod h1:bIjVDfnllIU7BJ2DNgfnXvpSvtn8VRwhlsaeUTyUS44= +golang.org/x/net v0.25.0/go.mod h1:JkAGAh7GEvH74S6FOH42FLoXpXbE/aqXSrIQjXgsiwM= +golang.org/x/net v0.28.0 h1:a9JDOJc5GMUJ0+UDqmLT86WiEy7iWyIhz8gz8E4e5hE= +golang.org/x/net v0.28.0/go.mod h1:yqtgsTWOOnlGLG9GFRrK3++bGOUEkNBoHZc8MEDWPNg= golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sync v0.3.0/go.mod h1:FU7BRWz2tNW+3quACPkgCx/L+uEAv1htQ0V83Z9Rj+Y= +golang.org/x/sync v0.6.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk= +golang.org/x/sync v0.7.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk= +golang.org/x/sync v0.8.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk= golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= @@ -43,27 +72,40 @@ golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBc golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.8.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/sys v0.13.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.17.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/sys v0.20.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/sys v0.23.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/telemetry v0.0.0-20240228155512-f48c80bd79b2/go.mod h1:TeRTkGYfJXctD9OcfyVLyj2J3IxLnKwHJR8f4D8a3YE= golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8= golang.org/x/term v0.5.0/go.mod h1:jMB1sMXY+tzblOD4FWmEbocvup2/aLOaQEp7JmGp78k= golang.org/x/term v0.8.0/go.mod h1:xPskH00ivmX89bAKVGSKKtLOWNx2+17Eiy94tnKShWo= -golang.org/x/term v0.13.0/go.mod h1:LTmsnFJwVN6bCy1rVCoS+qHT1HhALEFxKncY3WNNh4U= +golang.org/x/term v0.12.0/go.mod h1:owVbMEjm3cBLCHdkQu9b1opXd4ETQWc3BhuQGKgXgvU= +golang.org/x/term v0.17.0/go.mod h1:lLRBjIVuehSbZlaOtGMbcMncT+aqLLLmKrsjNrUguwk= +golang.org/x/term v0.20.0/go.mod h1:8UkIAJTvZgivsXaD6/pH6U9ecQzZ45awqEOzuCvwpFY= +golang.org/x/term v0.23.0/go.mod h1:DgV24QBUrK6jhZXl+20l6UWznPlwAHm1Q1mGHtydmSk= golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ= golang.org/x/text v0.3.8/go.mod h1:E6s5w1FMmriuDzIBO73fBruAKo1PCIq6d2Q6DHfQ8WQ= golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8= golang.org/x/text v0.9.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8= -golang.org/x/text v0.13.0 h1:ablQoSUd0tRdKxZewP80B+BaqeKJuVhuRxj/dkrun3k= golang.org/x/text v0.13.0/go.mod h1:TvPlkZtksWOMsz7fbANvkp4WM8x/WCo/om8BMLbz+aE= +golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU= +golang.org/x/text v0.15.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU= +golang.org/x/text v0.17.0 h1:XtiM5bkSOt+ewxlOE/aE/AKEHibwj/6gvWMl9Rsh0Qc= +golang.org/x/text v0.17.0/go.mod h1:BuEKDfySbSR4drPmRPG/7iBdf8hvFMuRexcpahXilzY= golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc= golang.org/x/tools v0.6.0/go.mod h1:Xwgl3UAJ/d3gWutnCtw505GrjyAbvKui8lOU390QaIU= +golang.org/x/tools v0.13.0/go.mod h1:HvlwmtVNQAhOuCjW7xxvovg8wbNq7LwfXh/k7wXUl58= +golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d/go.mod h1:aiJjzUbINMkxbQROHiO6hDPo2LHcIPhhQsa9DLh0yGk= golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= -gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= +gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk= +gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q= gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= diff --git a/gzip/gzip.go b/gzip/gzip.go index 230e4539e..23e0f968a 100644 --- a/gzip/gzip.go +++ b/gzip/gzip.go @@ -4,8 +4,8 @@ package gzip import ( + "github.com/generalmotors/kafka-go/compress/gzip" gz "github.com/klauspost/compress/gzip" - "github.com/segmentio/kafka-go/compress/gzip" ) const ( diff --git a/heartbeat.go b/heartbeat.go index a0444dae1..c2fe100f9 100644 --- a/heartbeat.go +++ b/heartbeat.go @@ -7,7 +7,7 @@ import ( "net" "time" - heartbeatAPI "github.com/segmentio/kafka-go/protocol/heartbeat" + heartbeatAPI "github.com/generalmotors/kafka-go/protocol/heartbeat" ) // HeartbeatRequest represents a heartbeat sent to kafka to indicate consume liveness. diff --git a/incrementalalterconfigs.go b/incrementalalterconfigs.go index a14714d87..a5477ef7a 100644 --- a/incrementalalterconfigs.go +++ b/incrementalalterconfigs.go @@ -4,7 +4,7 @@ import ( "context" "net" - "github.com/segmentio/kafka-go/protocol/incrementalalterconfigs" + "github.com/generalmotors/kafka-go/protocol/incrementalalterconfigs" ) type ConfigOperation int8 diff --git a/incrementalalterconfigs_test.go b/incrementalalterconfigs_test.go index 9148d79d0..49b50a417 100644 --- a/incrementalalterconfigs_test.go +++ b/incrementalalterconfigs_test.go @@ -5,7 +5,7 @@ import ( "reflect" "testing" - ktesting "github.com/segmentio/kafka-go/testing" + ktesting "github.com/generalmotors/kafka-go/testing" ) func TestClientIncrementalAlterConfigs(t *testing.T) { diff --git a/initproducerid.go b/initproducerid.go index 5cc6b8f24..020ddaeb4 100644 --- a/initproducerid.go +++ b/initproducerid.go @@ -6,7 +6,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/initproducerid" + "github.com/generalmotors/kafka-go/protocol/initproducerid" ) // InitProducerIDRequest is the request structure for the InitProducerId function. diff --git a/initproducerid_test.go b/initproducerid_test.go index 061819e58..b9426786a 100644 --- a/initproducerid_test.go +++ b/initproducerid_test.go @@ -8,7 +8,7 @@ import ( "testing" "time" - ktesting "github.com/segmentio/kafka-go/testing" + ktesting "github.com/generalmotors/kafka-go/testing" ) func TestClientInitProducerId(t *testing.T) { diff --git a/joingroup.go b/joingroup.go index 30823a69a..66a9816c8 100644 --- a/joingroup.go +++ b/joingroup.go @@ -8,9 +8,9 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol" - "github.com/segmentio/kafka-go/protocol/consumer" - "github.com/segmentio/kafka-go/protocol/joingroup" + "github.com/generalmotors/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol/consumer" + "github.com/generalmotors/kafka-go/protocol/joingroup" ) // JoinGroupRequest is the request structure for the JoinGroup function. diff --git a/joingroup_test.go b/joingroup_test.go index 926f5b4a6..06859d1f5 100644 --- a/joingroup_test.go +++ b/joingroup_test.go @@ -9,7 +9,7 @@ import ( "testing" "time" - ktesting "github.com/segmentio/kafka-go/testing" + ktesting "github.com/generalmotors/kafka-go/testing" ) func TestClientJoinGroup(t *testing.T) { diff --git a/kafka.go b/kafka.go index d2d36e413..636c48e86 100644 --- a/kafka.go +++ b/kafka.go @@ -1,6 +1,6 @@ package kafka -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" // Broker represents a kafka broker in a kafka cluster. type Broker struct { diff --git a/leavegroup.go b/leavegroup.go index ad59a55c0..cbe7c3164 100644 --- a/leavegroup.go +++ b/leavegroup.go @@ -7,7 +7,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/leavegroup" + "github.com/generalmotors/kafka-go/protocol/leavegroup" ) // LeaveGroupRequest is the request structure for the LeaveGroup function. diff --git a/listgroups.go b/listgroups.go index 229de9352..b1ee1896a 100644 --- a/listgroups.go +++ b/listgroups.go @@ -5,7 +5,7 @@ import ( "context" "net" - "github.com/segmentio/kafka-go/protocol/listgroups" + "github.com/generalmotors/kafka-go/protocol/listgroups" ) // ListGroupsRequest is a request to the ListGroups API. diff --git a/listoffset.go b/listoffset.go index 11c5d04b4..d319d48d0 100644 --- a/listoffset.go +++ b/listoffset.go @@ -7,7 +7,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/listoffsets" + "github.com/generalmotors/kafka-go/protocol/listoffsets" ) // OffsetRequest represents a request to retrieve a single partition offset. diff --git a/listpartitionreassignments.go b/listpartitionreassignments.go index aa01fff3f..c5571decb 100644 --- a/listpartitionreassignments.go +++ b/listpartitionreassignments.go @@ -5,7 +5,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/listpartitionreassignments" + "github.com/generalmotors/kafka-go/protocol/listpartitionreassignments" ) // ListPartitionReassignmentsRequest is a request to the ListPartitionReassignments API. diff --git a/listpartitionreassignments_test.go b/listpartitionreassignments_test.go index fd2c31789..3d0ffef53 100644 --- a/listpartitionreassignments_test.go +++ b/listpartitionreassignments_test.go @@ -4,7 +4,7 @@ import ( "context" "testing" - ktesting "github.com/segmentio/kafka-go/testing" + ktesting "github.com/generalmotors/kafka-go/testing" ) func TestClientListPartitionReassignments(t *testing.T) { diff --git a/lz4/lz4.go b/lz4/lz4.go index 53a47677f..06674d5f4 100644 --- a/lz4/lz4.go +++ b/lz4/lz4.go @@ -3,7 +3,7 @@ // codec, which is now always included. package lz4 -import "github.com/segmentio/kafka-go/compress/lz4" +import "github.com/generalmotors/kafka-go/compress/lz4" const ( Code = 3 diff --git a/message_test.go b/message_test.go index 383cd2269..fe535d806 100644 --- a/message_test.go +++ b/message_test.go @@ -12,10 +12,10 @@ import ( "testing" "time" - "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/generalmotors/kafka-go/compress/gzip" + "github.com/generalmotors/kafka-go/compress/lz4" + "github.com/generalmotors/kafka-go/compress/snappy" + "github.com/generalmotors/kafka-go/compress/zstd" "github.com/stretchr/testify/require" ) diff --git a/metadata.go b/metadata.go index 429a6a260..2b3791919 100644 --- a/metadata.go +++ b/metadata.go @@ -6,7 +6,7 @@ import ( "net" "time" - metadataAPI "github.com/segmentio/kafka-go/protocol/metadata" + metadataAPI "github.com/generalmotors/kafka-go/protocol/metadata" ) // MetadataRequest represents a request sent to a kafka broker to retrieve its diff --git a/offsetcommit.go b/offsetcommit.go index 260fe4bc9..34bd948a0 100644 --- a/offsetcommit.go +++ b/offsetcommit.go @@ -7,7 +7,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/offsetcommit" + "github.com/generalmotors/kafka-go/protocol/offsetcommit" ) // OffsetCommit represent the commit of an offset to a partition. diff --git a/offsetdelete.go b/offsetdelete.go index ea526eb25..4cd11414a 100644 --- a/offsetdelete.go +++ b/offsetdelete.go @@ -6,7 +6,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/offsetdelete" + "github.com/generalmotors/kafka-go/protocol/offsetdelete" ) // OffsetDelete deletes the offset for a consumer group on a particular topic diff --git a/offsetdelete_test.go b/offsetdelete_test.go index e66b38fd3..6e7993adb 100644 --- a/offsetdelete_test.go +++ b/offsetdelete_test.go @@ -8,7 +8,7 @@ import ( "testing" "time" - ktesting "github.com/segmentio/kafka-go/testing" + ktesting "github.com/generalmotors/kafka-go/testing" ) func TestClientDeleteOffset(t *testing.T) { diff --git a/offsetfetch.go b/offsetfetch.go index b85bc5c83..8bf02478f 100644 --- a/offsetfetch.go +++ b/offsetfetch.go @@ -7,7 +7,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/offsetfetch" + "github.com/generalmotors/kafka-go/protocol/offsetfetch" ) // OffsetFetchRequest represents a request sent to a kafka broker to read the diff --git a/offsetfetch_test.go b/offsetfetch_test.go index 7f244700d..94e878d01 100644 --- a/offsetfetch_test.go +++ b/offsetfetch_test.go @@ -8,7 +8,7 @@ import ( "testing" "time" - ktesting "github.com/segmentio/kafka-go/testing" + ktesting "github.com/generalmotors/kafka-go/testing" ) func TestOffsetFetchResponseV1(t *testing.T) { diff --git a/produce.go b/produce.go index 72d1ed09b..3e04169c6 100644 --- a/produce.go +++ b/produce.go @@ -10,8 +10,8 @@ import ( "strconv" "time" - "github.com/segmentio/kafka-go/protocol" - produceAPI "github.com/segmentio/kafka-go/protocol/produce" + "github.com/generalmotors/kafka-go/protocol" + produceAPI "github.com/generalmotors/kafka-go/protocol/produce" ) type RequiredAcks int diff --git a/produce_test.go b/produce_test.go index 49437781d..afe430789 100644 --- a/produce_test.go +++ b/produce_test.go @@ -6,7 +6,7 @@ import ( "testing" "time" - "github.com/segmentio/kafka-go/compress" + "github.com/generalmotors/kafka-go/compress" ) func TestRequiredAcks(t *testing.T) { diff --git a/protocol/addoffsetstotxn/addoffsetstotxn.go b/protocol/addoffsetstotxn/addoffsetstotxn.go index 390e0db43..97e46fed3 100644 --- a/protocol/addoffsetstotxn/addoffsetstotxn.go +++ b/protocol/addoffsetstotxn/addoffsetstotxn.go @@ -1,6 +1,6 @@ package addoffsetstotxn -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/addoffsetstotxn/addoffsetstotxn_test.go b/protocol/addoffsetstotxn/addoffsetstotxn_test.go index cd02c37b7..87775f3e1 100644 --- a/protocol/addoffsetstotxn/addoffsetstotxn_test.go +++ b/protocol/addoffsetstotxn/addoffsetstotxn_test.go @@ -3,8 +3,8 @@ package addoffsetstotxn_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/addoffsetstotxn" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/addoffsetstotxn" + "github.com/generalmotors/kafka-go/protocol/prototest" ) func TestAddOffsetsToTxnRequest(t *testing.T) { diff --git a/protocol/addpartitionstotxn/addpartitionstotxn.go b/protocol/addpartitionstotxn/addpartitionstotxn.go index b204da350..d14be8bb3 100644 --- a/protocol/addpartitionstotxn/addpartitionstotxn.go +++ b/protocol/addpartitionstotxn/addpartitionstotxn.go @@ -1,6 +1,6 @@ package addpartitionstotxn -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/addpartitionstotxn/addpartitionstotxn_test.go b/protocol/addpartitionstotxn/addpartitionstotxn_test.go index 91baaa13a..4bce98001 100644 --- a/protocol/addpartitionstotxn/addpartitionstotxn_test.go +++ b/protocol/addpartitionstotxn/addpartitionstotxn_test.go @@ -3,8 +3,8 @@ package addpartitionstotxn_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/addpartitionstotxn" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/addpartitionstotxn" + "github.com/generalmotors/kafka-go/protocol/prototest" ) func TestAddPartitionsToTxnRequest(t *testing.T) { diff --git a/protocol/alterclientquotas/alterclientquotas.go b/protocol/alterclientquotas/alterclientquotas.go index c657d92ac..cfbef130a 100644 --- a/protocol/alterclientquotas/alterclientquotas.go +++ b/protocol/alterclientquotas/alterclientquotas.go @@ -1,6 +1,6 @@ package alterclientquotas -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/alterclientquotas/alterclientquotas_test.go b/protocol/alterclientquotas/alterclientquotas_test.go index cf1b82f6b..b353b99a8 100644 --- a/protocol/alterclientquotas/alterclientquotas_test.go +++ b/protocol/alterclientquotas/alterclientquotas_test.go @@ -3,8 +3,8 @@ package alterclientquotas_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/alterclientquotas" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/alterclientquotas" + "github.com/generalmotors/kafka-go/protocol/prototest" ) const ( diff --git a/protocol/alterconfigs/alterconfigs.go b/protocol/alterconfigs/alterconfigs.go index 6c7d0d5db..06b4539ca 100644 --- a/protocol/alterconfigs/alterconfigs.go +++ b/protocol/alterconfigs/alterconfigs.go @@ -1,6 +1,6 @@ package alterconfigs -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/alterconfigs/alterconfigs_test.go b/protocol/alterconfigs/alterconfigs_test.go index 80a00b380..63969102d 100644 --- a/protocol/alterconfigs/alterconfigs_test.go +++ b/protocol/alterconfigs/alterconfigs_test.go @@ -3,8 +3,8 @@ package alterconfigs_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/alterconfigs" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/alterconfigs" + "github.com/generalmotors/kafka-go/protocol/prototest" ) const ( diff --git a/protocol/alterpartitionreassignments/alterpartitionreassignments.go b/protocol/alterpartitionreassignments/alterpartitionreassignments.go index 7f8d2ed2f..597196a1c 100644 --- a/protocol/alterpartitionreassignments/alterpartitionreassignments.go +++ b/protocol/alterpartitionreassignments/alterpartitionreassignments.go @@ -1,6 +1,6 @@ package alterpartitionreassignments -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/alterpartitionreassignments/alterpartitionreassignments_test.go b/protocol/alterpartitionreassignments/alterpartitionreassignments_test.go index 1e3a860b9..d736fdccf 100644 --- a/protocol/alterpartitionreassignments/alterpartitionreassignments_test.go +++ b/protocol/alterpartitionreassignments/alterpartitionreassignments_test.go @@ -3,8 +3,8 @@ package alterpartitionreassignments_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/alterpartitionreassignments" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/alterpartitionreassignments" + "github.com/generalmotors/kafka-go/protocol/prototest" ) const ( diff --git a/protocol/alteruserscramcredentials/alteruserscramcredentials.go b/protocol/alteruserscramcredentials/alteruserscramcredentials.go index b5369be20..2dec92475 100644 --- a/protocol/alteruserscramcredentials/alteruserscramcredentials.go +++ b/protocol/alteruserscramcredentials/alteruserscramcredentials.go @@ -1,6 +1,6 @@ package alteruserscramcredentials -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/alteruserscramcredentials/alteruserscramcredentials_test.go b/protocol/alteruserscramcredentials/alteruserscramcredentials_test.go index 850a59557..388ea0b98 100644 --- a/protocol/alteruserscramcredentials/alteruserscramcredentials_test.go +++ b/protocol/alteruserscramcredentials/alteruserscramcredentials_test.go @@ -3,8 +3,8 @@ package alteruserscramcredentials_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/alteruserscramcredentials" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/alteruserscramcredentials" + "github.com/generalmotors/kafka-go/protocol/prototest" ) const ( diff --git a/protocol/apiversions/apiversions.go b/protocol/apiversions/apiversions.go index 1c5745582..477d1d513 100644 --- a/protocol/apiversions/apiversions.go +++ b/protocol/apiversions/apiversions.go @@ -1,6 +1,6 @@ package apiversions -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/apiversions/apiversions_test.go b/protocol/apiversions/apiversions_test.go index 555bb4a0f..fa1f94fc5 100644 --- a/protocol/apiversions/apiversions_test.go +++ b/protocol/apiversions/apiversions_test.go @@ -3,8 +3,8 @@ package apiversions_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/apiversions" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/apiversions" + "github.com/generalmotors/kafka-go/protocol/prototest" ) const ( diff --git a/protocol/consumer/consumer_test.go b/protocol/consumer/consumer_test.go index 760336e7d..f7b2cdf75 100644 --- a/protocol/consumer/consumer_test.go +++ b/protocol/consumer/consumer_test.go @@ -4,8 +4,8 @@ import ( "reflect" "testing" - "github.com/segmentio/kafka-go/protocol" - "github.com/segmentio/kafka-go/protocol/consumer" + "github.com/generalmotors/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol/consumer" ) func TestSubscription(t *testing.T) { diff --git a/protocol/createacls/createacls.go b/protocol/createacls/createacls.go index aad0cc07c..f029b757e 100644 --- a/protocol/createacls/createacls.go +++ b/protocol/createacls/createacls.go @@ -1,6 +1,6 @@ package createacls -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/createacls/createacls_test.go b/protocol/createacls/createacls_test.go index 61b48c805..11506469e 100644 --- a/protocol/createacls/createacls_test.go +++ b/protocol/createacls/createacls_test.go @@ -3,8 +3,8 @@ package createacls_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/createacls" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/createacls" + "github.com/generalmotors/kafka-go/protocol/prototest" ) const ( diff --git a/protocol/createpartitions/createpartitions.go b/protocol/createpartitions/createpartitions.go index 4b86b4408..fbf26453a 100644 --- a/protocol/createpartitions/createpartitions.go +++ b/protocol/createpartitions/createpartitions.go @@ -1,6 +1,6 @@ package createpartitions -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/createpartitions/createpartitions_test.go b/protocol/createpartitions/createpartitions_test.go index 56b6671e0..db7c29a42 100644 --- a/protocol/createpartitions/createpartitions_test.go +++ b/protocol/createpartitions/createpartitions_test.go @@ -3,8 +3,8 @@ package createpartitions_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/createpartitions" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/createpartitions" + "github.com/generalmotors/kafka-go/protocol/prototest" ) const ( diff --git a/protocol/createtopics/createtopics.go b/protocol/createtopics/createtopics.go index 62c597fb1..06c2cc501 100644 --- a/protocol/createtopics/createtopics.go +++ b/protocol/createtopics/createtopics.go @@ -1,6 +1,6 @@ package createtopics -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/deleteacls/deleteacls.go b/protocol/deleteacls/deleteacls.go index 7f0f002f3..a22791b4d 100644 --- a/protocol/deleteacls/deleteacls.go +++ b/protocol/deleteacls/deleteacls.go @@ -1,6 +1,6 @@ package deleteacls -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/deleteacls/deleteacls_test.go b/protocol/deleteacls/deleteacls_test.go index 51f8dd204..8e29a8d67 100644 --- a/protocol/deleteacls/deleteacls_test.go +++ b/protocol/deleteacls/deleteacls_test.go @@ -3,8 +3,8 @@ package deleteacls_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/deleteacls" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/deleteacls" + "github.com/generalmotors/kafka-go/protocol/prototest" ) const ( diff --git a/protocol/deletegroups/deletegroups.go b/protocol/deletegroups/deletegroups.go index 759dfc2fe..0337bdd91 100644 --- a/protocol/deletegroups/deletegroups.go +++ b/protocol/deletegroups/deletegroups.go @@ -1,6 +1,6 @@ package deletegroups -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/deletegroups/deletegroups_test.go b/protocol/deletegroups/deletegroups_test.go index 141ab3bcc..06a4f96c9 100644 --- a/protocol/deletegroups/deletegroups_test.go +++ b/protocol/deletegroups/deletegroups_test.go @@ -3,8 +3,8 @@ package deletegroups_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/deletegroups" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/deletegroups" + "github.com/generalmotors/kafka-go/protocol/prototest" ) func TestDeleteGroupsRequest(t *testing.T) { diff --git a/protocol/deletetopics/deletetopics.go b/protocol/deletetopics/deletetopics.go index 3af5a0014..a365c6c6d 100644 --- a/protocol/deletetopics/deletetopics.go +++ b/protocol/deletetopics/deletetopics.go @@ -1,6 +1,6 @@ package deletetopics -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/deletetopics/deletetopics_test.go b/protocol/deletetopics/deletetopics_test.go index 02d08d933..cd270f592 100644 --- a/protocol/deletetopics/deletetopics_test.go +++ b/protocol/deletetopics/deletetopics_test.go @@ -3,8 +3,8 @@ package deletetopics_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/deletetopics" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/deletetopics" + "github.com/generalmotors/kafka-go/protocol/prototest" ) const ( diff --git a/protocol/describeacls/describeacls.go b/protocol/describeacls/describeacls.go index 93a7d2ed7..373f77e1c 100644 --- a/protocol/describeacls/describeacls.go +++ b/protocol/describeacls/describeacls.go @@ -1,6 +1,6 @@ package describeacls -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/describeacls/describeacls_test.go b/protocol/describeacls/describeacls_test.go index 8fd45fffc..01936b8e9 100644 --- a/protocol/describeacls/describeacls_test.go +++ b/protocol/describeacls/describeacls_test.go @@ -3,8 +3,8 @@ package describeacls_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/describeacls" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/describeacls" + "github.com/generalmotors/kafka-go/protocol/prototest" ) const ( diff --git a/protocol/describeclientquotas/describeclientquotas.go b/protocol/describeclientquotas/describeclientquotas.go index e137776bf..793ba974b 100644 --- a/protocol/describeclientquotas/describeclientquotas.go +++ b/protocol/describeclientquotas/describeclientquotas.go @@ -1,6 +1,6 @@ package describeclientquotas -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/describeclientquotas/describeclientquotas_test.go b/protocol/describeclientquotas/describeclientquotas_test.go index 3bb404c27..dc810968d 100644 --- a/protocol/describeclientquotas/describeclientquotas_test.go +++ b/protocol/describeclientquotas/describeclientquotas_test.go @@ -3,8 +3,8 @@ package describeclientquotas_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/describeclientquotas" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/describeclientquotas" + "github.com/generalmotors/kafka-go/protocol/prototest" ) const ( diff --git a/protocol/describeconfigs/describeconfigs.go b/protocol/describeconfigs/describeconfigs.go index 09c91841f..0c3187582 100644 --- a/protocol/describeconfigs/describeconfigs.go +++ b/protocol/describeconfigs/describeconfigs.go @@ -3,7 +3,7 @@ package describeconfigs import ( "strconv" - "github.com/segmentio/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol" ) const ( diff --git a/protocol/describeconfigs/describeconfigs_test.go b/protocol/describeconfigs/describeconfigs_test.go index efaa417ec..eba82551b 100644 --- a/protocol/describeconfigs/describeconfigs_test.go +++ b/protocol/describeconfigs/describeconfigs_test.go @@ -7,7 +7,7 @@ import ( "reflect" "testing" - "github.com/segmentio/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol" "github.com/stretchr/testify/require" ) diff --git a/protocol/describegroups/describegroups.go b/protocol/describegroups/describegroups.go index a4d12048a..04fbe8ba5 100644 --- a/protocol/describegroups/describegroups.go +++ b/protocol/describegroups/describegroups.go @@ -1,7 +1,7 @@ package describegroups import ( - "github.com/segmentio/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol" ) func init() { diff --git a/protocol/describeuserscramcredentials/describeuserscramcredentials.go b/protocol/describeuserscramcredentials/describeuserscramcredentials.go index e923b9a11..5bcc42008 100644 --- a/protocol/describeuserscramcredentials/describeuserscramcredentials.go +++ b/protocol/describeuserscramcredentials/describeuserscramcredentials.go @@ -1,6 +1,6 @@ package describeuserscramcredentials -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/describeuserscramcredentials/describeuserscramcredentials_test.go b/protocol/describeuserscramcredentials/describeuserscramcredentials_test.go index 3f2df6ff2..8dbe7c96f 100644 --- a/protocol/describeuserscramcredentials/describeuserscramcredentials_test.go +++ b/protocol/describeuserscramcredentials/describeuserscramcredentials_test.go @@ -3,8 +3,8 @@ package describeuserscramcredentials_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/describeuserscramcredentials" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/describeuserscramcredentials" + "github.com/generalmotors/kafka-go/protocol/prototest" ) const ( diff --git a/protocol/electleaders/electleaders.go b/protocol/electleaders/electleaders.go index cd36ff5d7..50510a4f4 100644 --- a/protocol/electleaders/electleaders.go +++ b/protocol/electleaders/electleaders.go @@ -1,6 +1,6 @@ package electleaders -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/electleaders/electleaders_test.go b/protocol/electleaders/electleaders_test.go index b7b91ec08..0a883ddeb 100644 --- a/protocol/electleaders/electleaders_test.go +++ b/protocol/electleaders/electleaders_test.go @@ -3,8 +3,8 @@ package electleaders_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/electleaders" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/electleaders" + "github.com/generalmotors/kafka-go/protocol/prototest" ) const ( diff --git a/protocol/endtxn/endtxn.go b/protocol/endtxn/endtxn.go index c3799cb88..ff1ad7318 100644 --- a/protocol/endtxn/endtxn.go +++ b/protocol/endtxn/endtxn.go @@ -1,6 +1,6 @@ package endtxn -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/endtxn/endtxn_test.go b/protocol/endtxn/endtxn_test.go index 09f7c3e24..83d76f251 100644 --- a/protocol/endtxn/endtxn_test.go +++ b/protocol/endtxn/endtxn_test.go @@ -3,8 +3,8 @@ package endtxn_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/endtxn" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/endtxn" + "github.com/generalmotors/kafka-go/protocol/prototest" ) func TestEndTxnRequest(t *testing.T) { diff --git a/protocol/fetch/fetch.go b/protocol/fetch/fetch.go index 6ce7bae1b..f1f2d1029 100644 --- a/protocol/fetch/fetch.go +++ b/protocol/fetch/fetch.go @@ -3,7 +3,7 @@ package fetch import ( "fmt" - "github.com/segmentio/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol" ) func init() { diff --git a/protocol/fetch/fetch_test.go b/protocol/fetch/fetch_test.go index 3f7f820d9..2ec7ad41a 100644 --- a/protocol/fetch/fetch_test.go +++ b/protocol/fetch/fetch_test.go @@ -4,9 +4,9 @@ import ( "testing" "time" - "github.com/segmentio/kafka-go/protocol" - "github.com/segmentio/kafka-go/protocol/fetch" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol/fetch" + "github.com/generalmotors/kafka-go/protocol/prototest" ) const ( diff --git a/protocol/findcoordinator/findcoordinator.go b/protocol/findcoordinator/findcoordinator.go index 0306e206d..45ad29e71 100644 --- a/protocol/findcoordinator/findcoordinator.go +++ b/protocol/findcoordinator/findcoordinator.go @@ -1,6 +1,6 @@ package findcoordinator -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/heartbeat/heartbeat.go b/protocol/heartbeat/heartbeat.go index cf4c11185..d7ad4c45b 100644 --- a/protocol/heartbeat/heartbeat.go +++ b/protocol/heartbeat/heartbeat.go @@ -1,6 +1,6 @@ package heartbeat -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/heartbeat/heartbeat_test.go b/protocol/heartbeat/heartbeat_test.go index 0919fdf97..3cba71730 100644 --- a/protocol/heartbeat/heartbeat_test.go +++ b/protocol/heartbeat/heartbeat_test.go @@ -3,8 +3,8 @@ package heartbeat_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/heartbeat" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/heartbeat" + "github.com/generalmotors/kafka-go/protocol/prototest" ) func TestHeartbeatRequest(t *testing.T) { diff --git a/protocol/incrementalalterconfigs/incrementalalterconfigs.go b/protocol/incrementalalterconfigs/incrementalalterconfigs.go index f4328efc1..1c3433763 100644 --- a/protocol/incrementalalterconfigs/incrementalalterconfigs.go +++ b/protocol/incrementalalterconfigs/incrementalalterconfigs.go @@ -4,7 +4,7 @@ import ( "errors" "strconv" - "github.com/segmentio/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol" ) const ( diff --git a/protocol/incrementalalterconfigs/incrementalalterconfigs_test.go b/protocol/incrementalalterconfigs/incrementalalterconfigs_test.go index aa537d397..3c192378d 100644 --- a/protocol/incrementalalterconfigs/incrementalalterconfigs_test.go +++ b/protocol/incrementalalterconfigs/incrementalalterconfigs_test.go @@ -3,8 +3,8 @@ package incrementalalterconfigs_test import ( "testing" - "github.com/segmentio/kafka-go/protocol" - "github.com/segmentio/kafka-go/protocol/incrementalalterconfigs" + "github.com/generalmotors/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol/incrementalalterconfigs" ) const ( diff --git a/protocol/initproducerid/initproducerid.go b/protocol/initproducerid/initproducerid.go index 17f6ef7ea..7a09b6d5e 100644 --- a/protocol/initproducerid/initproducerid.go +++ b/protocol/initproducerid/initproducerid.go @@ -1,6 +1,6 @@ package initproducerid -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/initproducerid/initproducerid_test.go b/protocol/initproducerid/initproducerid_test.go index 5dd6a9178..f29a10408 100644 --- a/protocol/initproducerid/initproducerid_test.go +++ b/protocol/initproducerid/initproducerid_test.go @@ -3,8 +3,8 @@ package initproducerid_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/initproducerid" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/initproducerid" + "github.com/generalmotors/kafka-go/protocol/prototest" ) func TestInitProducerIDRequest(t *testing.T) { diff --git a/protocol/joingroup/joingroup.go b/protocol/joingroup/joingroup.go index a0738eed0..119ee0bd8 100644 --- a/protocol/joingroup/joingroup.go +++ b/protocol/joingroup/joingroup.go @@ -1,6 +1,6 @@ package joingroup -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/joingroup/joingroup_test.go b/protocol/joingroup/joingroup_test.go index 69162facb..e86962bb9 100644 --- a/protocol/joingroup/joingroup_test.go +++ b/protocol/joingroup/joingroup_test.go @@ -3,8 +3,8 @@ package joingroup_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/joingroup" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/joingroup" + "github.com/generalmotors/kafka-go/protocol/prototest" ) func TestJoinGroupReq(t *testing.T) { diff --git a/protocol/leavegroup/leavegroup.go b/protocol/leavegroup/leavegroup.go index 4dd8773e4..0fd8f06e8 100644 --- a/protocol/leavegroup/leavegroup.go +++ b/protocol/leavegroup/leavegroup.go @@ -1,6 +1,6 @@ package leavegroup -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/leavegroup/leavegroup_test.go b/protocol/leavegroup/leavegroup_test.go index de4556e93..86920dab0 100644 --- a/protocol/leavegroup/leavegroup_test.go +++ b/protocol/leavegroup/leavegroup_test.go @@ -3,8 +3,8 @@ package leavegroup_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/leavegroup" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/leavegroup" + "github.com/generalmotors/kafka-go/protocol/prototest" ) func TestLeaveGroupReq(t *testing.T) { diff --git a/protocol/listgroups/listgroups.go b/protocol/listgroups/listgroups.go index 136458a25..48a0213a0 100644 --- a/protocol/listgroups/listgroups.go +++ b/protocol/listgroups/listgroups.go @@ -1,7 +1,7 @@ package listgroups import ( - "github.com/segmentio/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol" ) func init() { diff --git a/protocol/listoffsets/listoffsets.go b/protocol/listoffsets/listoffsets.go index 059662d9a..f367a33e1 100644 --- a/protocol/listoffsets/listoffsets.go +++ b/protocol/listoffsets/listoffsets.go @@ -3,7 +3,7 @@ package listoffsets import ( "sort" - "github.com/segmentio/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol" ) func init() { diff --git a/protocol/listoffsets/listoffsets_test.go b/protocol/listoffsets/listoffsets_test.go index ffeb2ca99..92b396c56 100644 --- a/protocol/listoffsets/listoffsets_test.go +++ b/protocol/listoffsets/listoffsets_test.go @@ -3,8 +3,8 @@ package listoffsets_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/listoffsets" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/listoffsets" + "github.com/generalmotors/kafka-go/protocol/prototest" ) const ( diff --git a/protocol/listpartitionreassignments/listpartitionreassignments.go b/protocol/listpartitionreassignments/listpartitionreassignments.go index d26a64101..e1e7e6ff0 100644 --- a/protocol/listpartitionreassignments/listpartitionreassignments.go +++ b/protocol/listpartitionreassignments/listpartitionreassignments.go @@ -1,6 +1,6 @@ package listpartitionreassignments -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/listpartitionreassignments/listpartitionreassignments_test.go b/protocol/listpartitionreassignments/listpartitionreassignments_test.go index e32869faa..eb877d32a 100644 --- a/protocol/listpartitionreassignments/listpartitionreassignments_test.go +++ b/protocol/listpartitionreassignments/listpartitionreassignments_test.go @@ -3,8 +3,8 @@ package listpartitionreassignments_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/listpartitionreassignments" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/listpartitionreassignments" + "github.com/generalmotors/kafka-go/protocol/prototest" ) const ( diff --git a/protocol/metadata/metadata.go b/protocol/metadata/metadata.go index ac2031bda..7c9512d58 100644 --- a/protocol/metadata/metadata.go +++ b/protocol/metadata/metadata.go @@ -1,6 +1,6 @@ package metadata -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/metadata/metadata_test.go b/protocol/metadata/metadata_test.go index 168fd2785..604b19935 100644 --- a/protocol/metadata/metadata_test.go +++ b/protocol/metadata/metadata_test.go @@ -3,8 +3,8 @@ package metadata_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/metadata" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/metadata" + "github.com/generalmotors/kafka-go/protocol/prototest" ) const ( diff --git a/protocol/offsetcommit/offsetcommit.go b/protocol/offsetcommit/offsetcommit.go index 5844928a6..edf540058 100644 --- a/protocol/offsetcommit/offsetcommit.go +++ b/protocol/offsetcommit/offsetcommit.go @@ -1,6 +1,6 @@ package offsetcommit -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/offsetcommit/offsetcommit_test.go b/protocol/offsetcommit/offsetcommit_test.go index 3a9afd236..dfb2f278e 100644 --- a/protocol/offsetcommit/offsetcommit_test.go +++ b/protocol/offsetcommit/offsetcommit_test.go @@ -3,8 +3,8 @@ package offsetcommit_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/offsetcommit" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/offsetcommit" + "github.com/generalmotors/kafka-go/protocol/prototest" ) func TestOffsetCommitRequest(t *testing.T) { diff --git a/protocol/offsetdelete/offsetdelete.go b/protocol/offsetdelete/offsetdelete.go index bda619f3c..84d310ba2 100644 --- a/protocol/offsetdelete/offsetdelete.go +++ b/protocol/offsetdelete/offsetdelete.go @@ -1,6 +1,6 @@ package offsetdelete -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/offsetdelete/offsetdelete_test.go b/protocol/offsetdelete/offsetdelete_test.go index ed8d7ea94..78f4a0de7 100644 --- a/protocol/offsetdelete/offsetdelete_test.go +++ b/protocol/offsetdelete/offsetdelete_test.go @@ -3,8 +3,8 @@ package offsetdelete_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/offsetdelete" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/offsetdelete" + "github.com/generalmotors/kafka-go/protocol/prototest" ) func TestOffsetDeleteRequest(t *testing.T) { diff --git a/protocol/offsetfetch/offsetfetch.go b/protocol/offsetfetch/offsetfetch.go index 8f1096f5d..83e68a6ec 100644 --- a/protocol/offsetfetch/offsetfetch.go +++ b/protocol/offsetfetch/offsetfetch.go @@ -1,6 +1,6 @@ package offsetfetch -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/produce/produce.go b/protocol/produce/produce.go index 6d337c3cf..6b18c88ee 100644 --- a/protocol/produce/produce.go +++ b/protocol/produce/produce.go @@ -3,7 +3,7 @@ package produce import ( "fmt" - "github.com/segmentio/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol" ) func init() { diff --git a/protocol/produce/produce_test.go b/protocol/produce/produce_test.go index 276b7d463..d956e8eee 100644 --- a/protocol/produce/produce_test.go +++ b/protocol/produce/produce_test.go @@ -4,9 +4,9 @@ import ( "testing" "time" - "github.com/segmentio/kafka-go/protocol" - "github.com/segmentio/kafka-go/protocol/produce" - "github.com/segmentio/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol/produce" + "github.com/generalmotors/kafka-go/protocol/prototest" ) const ( diff --git a/protocol/prototest/bytes.go b/protocol/prototest/bytes.go index 3938e14d6..831c799a5 100644 --- a/protocol/prototest/bytes.go +++ b/protocol/prototest/bytes.go @@ -1,7 +1,7 @@ package prototest import ( - "github.com/segmentio/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol" ) // Bytes constructs a Bytes which exposes the content of b. diff --git a/protocol/prototest/prototest.go b/protocol/prototest/prototest.go index 56042426f..6d06c2488 100644 --- a/protocol/prototest/prototest.go +++ b/protocol/prototest/prototest.go @@ -7,7 +7,7 @@ import ( "reflect" "time" - "github.com/segmentio/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol" ) func deepEqual(x1, x2 interface{}) bool { diff --git a/protocol/prototest/reflect.go b/protocol/prototest/reflect.go index a266d688f..2415bc490 100644 --- a/protocol/prototest/reflect.go +++ b/protocol/prototest/reflect.go @@ -7,7 +7,7 @@ import ( "reflect" "time" - "github.com/segmentio/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol" ) var ( diff --git a/protocol/prototest/request.go b/protocol/prototest/request.go index c0197f25d..28c57a70e 100644 --- a/protocol/prototest/request.go +++ b/protocol/prototest/request.go @@ -8,7 +8,7 @@ import ( "io" "testing" - "github.com/segmentio/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol" ) func TestRequest(t *testing.T, version int16, msg protocol.Message) { diff --git a/protocol/prototest/response.go b/protocol/prototest/response.go index 9a66161f1..90616dbc4 100644 --- a/protocol/prototest/response.go +++ b/protocol/prototest/response.go @@ -8,7 +8,7 @@ import ( "io" "testing" - "github.com/segmentio/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol" ) func TestResponse(t *testing.T, version int16, msg protocol.Message) { diff --git a/protocol/rawproduce/rawproduce.go b/protocol/rawproduce/rawproduce.go index bad83138d..b4f466438 100644 --- a/protocol/rawproduce/rawproduce.go +++ b/protocol/rawproduce/rawproduce.go @@ -3,8 +3,8 @@ package rawproduce import ( "fmt" - "github.com/segmentio/kafka-go/protocol" - "github.com/segmentio/kafka-go/protocol/produce" + "github.com/generalmotors/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol/produce" ) func init() { diff --git a/protocol/rawproduce/rawproduce_test.go b/protocol/rawproduce/rawproduce_test.go index 2d987e711..f7b3d61b8 100644 --- a/protocol/rawproduce/rawproduce_test.go +++ b/protocol/rawproduce/rawproduce_test.go @@ -5,9 +5,9 @@ import ( "testing" "time" - "github.com/segmentio/kafka-go/protocol" - "github.com/segmentio/kafka-go/protocol/prototest" - "github.com/segmentio/kafka-go/protocol/rawproduce" + "github.com/generalmotors/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/rawproduce" ) const ( diff --git a/protocol/record.go b/protocol/record.go index e11af4dcc..7cfc87f05 100644 --- a/protocol/record.go +++ b/protocol/record.go @@ -7,7 +7,7 @@ import ( "io" "time" - "github.com/segmentio/kafka-go/compress" + "github.com/generalmotors/kafka-go/compress" ) // Attributes is a bitset representing special attributes set on records. diff --git a/protocol/saslauthenticate/saslauthenticate.go b/protocol/saslauthenticate/saslauthenticate.go index fdd7bfbcd..c01b56c8f 100644 --- a/protocol/saslauthenticate/saslauthenticate.go +++ b/protocol/saslauthenticate/saslauthenticate.go @@ -4,7 +4,7 @@ import ( "encoding/binary" "io" - "github.com/segmentio/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol" ) func init() { diff --git a/protocol/saslhandshake/saslhandshake.go b/protocol/saslhandshake/saslhandshake.go index aa72e8309..96bb97695 100644 --- a/protocol/saslhandshake/saslhandshake.go +++ b/protocol/saslhandshake/saslhandshake.go @@ -1,6 +1,6 @@ package saslhandshake -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/syncgroup/syncgroup.go b/protocol/syncgroup/syncgroup.go index e1ced0615..e4c2a27d7 100644 --- a/protocol/syncgroup/syncgroup.go +++ b/protocol/syncgroup/syncgroup.go @@ -1,6 +1,6 @@ package syncgroup -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/syncgroup/syncgroup_test.go b/protocol/syncgroup/syncgroup_test.go index 78d984dac..ec868283c 100644 --- a/protocol/syncgroup/syncgroup_test.go +++ b/protocol/syncgroup/syncgroup_test.go @@ -3,8 +3,8 @@ package syncgroup_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/prototest" - "github.com/segmentio/kafka-go/protocol/syncgroup" + "github.com/generalmotors/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/syncgroup" ) func TestSyncGroupReq(t *testing.T) { diff --git a/protocol/txnoffsetcommit/txnoffsetcommit.go b/protocol/txnoffsetcommit/txnoffsetcommit.go index 85f3f05e3..dac4bc172 100644 --- a/protocol/txnoffsetcommit/txnoffsetcommit.go +++ b/protocol/txnoffsetcommit/txnoffsetcommit.go @@ -1,6 +1,6 @@ package txnoffsetcommit -import "github.com/segmentio/kafka-go/protocol" +import "github.com/generalmotors/kafka-go/protocol" func init() { protocol.Register(&Request{}, &Response{}) diff --git a/protocol/txnoffsetcommit/txnoffsetcommit_test.go b/protocol/txnoffsetcommit/txnoffsetcommit_test.go index 7a740ab36..3eae3ee47 100644 --- a/protocol/txnoffsetcommit/txnoffsetcommit_test.go +++ b/protocol/txnoffsetcommit/txnoffsetcommit_test.go @@ -3,8 +3,8 @@ package txnoffsetcommit_test import ( "testing" - "github.com/segmentio/kafka-go/protocol/prototest" - "github.com/segmentio/kafka-go/protocol/txnoffsetcommit" + "github.com/generalmotors/kafka-go/protocol/prototest" + "github.com/generalmotors/kafka-go/protocol/txnoffsetcommit" ) func TestTxnOffsetCommitRequest(t *testing.T) { diff --git a/rawproduce.go b/rawproduce.go index 5928cb2f8..6db7fc02b 100644 --- a/rawproduce.go +++ b/rawproduce.go @@ -6,9 +6,9 @@ import ( "fmt" "net" - "github.com/segmentio/kafka-go/protocol" - produceAPI "github.com/segmentio/kafka-go/protocol/produce" - "github.com/segmentio/kafka-go/protocol/rawproduce" + "github.com/generalmotors/kafka-go/protocol" + produceAPI "github.com/generalmotors/kafka-go/protocol/produce" + "github.com/generalmotors/kafka-go/protocol/rawproduce" ) // RawProduceRequest represents a request sent to a kafka broker to produce records diff --git a/rawproduce_test.go b/rawproduce_test.go index 2c7fed782..6a8dfb7b5 100644 --- a/rawproduce_test.go +++ b/rawproduce_test.go @@ -6,8 +6,8 @@ import ( "testing" "time" - "github.com/segmentio/kafka-go/protocol" - ktesting "github.com/segmentio/kafka-go/testing" + "github.com/generalmotors/kafka-go/protocol" + ktesting "github.com/generalmotors/kafka-go/testing" ) func TestClientRawProduce(t *testing.T) { diff --git a/record.go b/record.go index 1750889ac..7d828b771 100644 --- a/record.go +++ b/record.go @@ -1,7 +1,7 @@ package kafka import ( - "github.com/segmentio/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol" ) // Header is a key/value pair type representing headers set on records. diff --git a/sasl/aws_msk_iam/msk_iam.go b/sasl/aws_msk_iam/msk_iam.go index 4e341d398..7a701319c 100644 --- a/sasl/aws_msk_iam/msk_iam.go +++ b/sasl/aws_msk_iam/msk_iam.go @@ -12,7 +12,7 @@ import ( "time" sigv4 "github.com/aws/aws-sdk-go/aws/signer/v4" - "github.com/segmentio/kafka-go/sasl" + "github.com/generalmotors/kafka-go/sasl" ) const ( @@ -49,19 +49,20 @@ func (m *Mechanism) Name() string { // Start produces the authentication values required for AWS_MSK_IAM. It produces the following json as a byte array, // making use of the aws-sdk to produce the signed output. -// { -// "version" : "2020_10_22", -// "host" : "", -// "user-agent": "", -// "action": "kafka-cluster:Connect", -// "x-amz-algorithm" : "", -// "x-amz-credential" : "///kafka-cluster/aws4_request", -// "x-amz-date" : "", -// "x-amz-security-token" : "", -// "x-amz-signedheaders" : "host", -// "x-amz-expires" : "", -// "x-amz-signature" : "" -// } +// +// { +// "version" : "2020_10_22", +// "host" : "", +// "user-agent": "", +// "action": "kafka-cluster:Connect", +// "x-amz-algorithm" : "", +// "x-amz-credential" : "///kafka-cluster/aws4_request", +// "x-amz-date" : "", +// "x-amz-security-token" : "", +// "x-amz-signedheaders" : "host", +// "x-amz-expires" : "", +// "x-amz-signature" : "" +// } func (m *Mechanism) Start(ctx context.Context) (sess sasl.StateMachine, ir []byte, err error) { saslMeta := sasl.MetadataFromContext(ctx) if saslMeta == nil { diff --git a/sasl/aws_msk_iam/msk_iam_test.go b/sasl/aws_msk_iam/msk_iam_test.go index 1b3cc7a04..e7b3f4194 100644 --- a/sasl/aws_msk_iam/msk_iam_test.go +++ b/sasl/aws_msk_iam/msk_iam_test.go @@ -7,7 +7,7 @@ import ( "testing" "time" - "github.com/segmentio/kafka-go/sasl" + "github.com/generalmotors/kafka-go/sasl" "github.com/aws/aws-sdk-go/aws/credentials" sigv4 "github.com/aws/aws-sdk-go/aws/signer/v4" diff --git a/sasl/aws_msk_iam_v2/example_test.go b/sasl/aws_msk_iam_v2/example_test.go index e7bcfdbd1..49d8c75a3 100644 --- a/sasl/aws_msk_iam_v2/example_test.go +++ b/sasl/aws_msk_iam_v2/example_test.go @@ -6,8 +6,8 @@ import ( "time" "github.com/aws/aws-sdk-go-v2/config" - "github.com/segmentio/kafka-go" - "github.com/segmentio/kafka-go/sasl/aws_msk_iam_v2" + "github.com/generalmotors/kafka-go" + "github.com/generalmotors/kafka-go/sasl/aws_msk_iam_v2" ) func main() { diff --git a/sasl/aws_msk_iam_v2/msk_iam.go b/sasl/aws_msk_iam_v2/msk_iam.go index 7fa49337f..dd6992ba8 100644 --- a/sasl/aws_msk_iam_v2/msk_iam.go +++ b/sasl/aws_msk_iam_v2/msk_iam.go @@ -13,7 +13,7 @@ import ( "github.com/aws/aws-sdk-go-v2/aws" signer "github.com/aws/aws-sdk-go-v2/aws/signer/v4" - "github.com/segmentio/kafka-go/sasl" + "github.com/generalmotors/kafka-go/sasl" ) const ( diff --git a/sasl/aws_msk_iam_v2/msk_iam_test.go b/sasl/aws_msk_iam_v2/msk_iam_test.go index e0fe014da..0ed79b72e 100644 --- a/sasl/aws_msk_iam_v2/msk_iam_test.go +++ b/sasl/aws_msk_iam_v2/msk_iam_test.go @@ -8,7 +8,7 @@ import ( "time" "github.com/aws/aws-sdk-go-v2/aws" - "github.com/segmentio/kafka-go/sasl" + "github.com/generalmotors/kafka-go/sasl" "github.com/stretchr/testify/assert" signer "github.com/aws/aws-sdk-go-v2/aws/signer/v4" diff --git a/sasl/azure_event_hubs_entra/README.md b/sasl/azure_event_hubs_entra/README.md index 3561a8381..e63ee0adf 100755 --- a/sasl/azure_event_hubs_entra/README.md +++ b/sasl/azure_event_hubs_entra/README.md @@ -23,8 +23,8 @@ import ( "os" "github.com/Azure/azure-sdk-for-go/sdk/azidentity" - "github.com/segmentio/kafka-go" - "github.com/segmentio/kafka-go/sasl/azure_event_hubs_entra" + "github.com/generalmotors/kafka-go" + "github.com/generalmotors/kafka-go/sasl/azure_event_hubs_entra" ) func main() { diff --git a/sasl/azure_event_hubs_entra/azure_event_hubs_entra.go b/sasl/azure_event_hubs_entra/azure_event_hubs_entra.go index 3ac988658..f0cba28c7 100755 --- a/sasl/azure_event_hubs_entra/azure_event_hubs_entra.go +++ b/sasl/azure_event_hubs_entra/azure_event_hubs_entra.go @@ -7,7 +7,7 @@ import ( "github.com/Azure/azure-sdk-for-go/sdk/azcore" "github.com/Azure/azure-sdk-for-go/sdk/azcore/policy" - "github.com/segmentio/kafka-go/sasl" + "github.com/generalmotors/kafka-go/sasl" ) type Mechanism struct { diff --git a/sasl/azure_event_hubs_entra/azure_event_hubs_entra_test.go b/sasl/azure_event_hubs_entra/azure_event_hubs_entra_test.go index a7a20f0bd..6ae576b45 100755 --- a/sasl/azure_event_hubs_entra/azure_event_hubs_entra_test.go +++ b/sasl/azure_event_hubs_entra/azure_event_hubs_entra_test.go @@ -7,7 +7,7 @@ import ( "github.com/Azure/azure-sdk-for-go/sdk/azcore" "github.com/Azure/azure-sdk-for-go/sdk/azcore/policy" - "github.com/segmentio/kafka-go/sasl" + "github.com/generalmotors/kafka-go/sasl" ) type MockTokenCredential struct { diff --git a/sasl/plain/plain.go b/sasl/plain/plain.go index 10c7632d2..47ad17cc8 100644 --- a/sasl/plain/plain.go +++ b/sasl/plain/plain.go @@ -4,7 +4,7 @@ import ( "context" "fmt" - "github.com/segmentio/kafka-go/sasl" + "github.com/generalmotors/kafka-go/sasl" ) // Mechanism implements the PLAIN mechanism and passes the credentials in clear diff --git a/sasl/sasl_test.go b/sasl/sasl_test.go index a4101391a..0f376c36c 100644 --- a/sasl/sasl_test.go +++ b/sasl/sasl_test.go @@ -5,11 +5,11 @@ import ( "testing" "time" - "github.com/segmentio/kafka-go" - "github.com/segmentio/kafka-go/sasl" - "github.com/segmentio/kafka-go/sasl/plain" - "github.com/segmentio/kafka-go/sasl/scram" - ktesting "github.com/segmentio/kafka-go/testing" + "github.com/generalmotors/kafka-go" + "github.com/generalmotors/kafka-go/sasl" + "github.com/generalmotors/kafka-go/sasl/plain" + "github.com/generalmotors/kafka-go/sasl/scram" + ktesting "github.com/generalmotors/kafka-go/testing" ) const ( diff --git a/sasl/scram/scram.go b/sasl/scram/scram.go index b29885f32..4319bcdee 100644 --- a/sasl/scram/scram.go +++ b/sasl/scram/scram.go @@ -6,7 +6,7 @@ import ( "crypto/sha512" "hash" - "github.com/segmentio/kafka-go/sasl" + "github.com/generalmotors/kafka-go/sasl" "github.com/xdg-go/scram" ) diff --git a/snappy/snappy.go b/snappy/snappy.go index 0ffddafbc..18f3891f5 100644 --- a/snappy/snappy.go +++ b/snappy/snappy.go @@ -3,7 +3,7 @@ // codec, which is now always included. package snappy -import "github.com/segmentio/kafka-go/compress/snappy" +import "github.com/generalmotors/kafka-go/compress/snappy" type CompressionCodec = snappy.Codec diff --git a/syncgroup.go b/syncgroup.go index ff37569e7..7cf0802d6 100644 --- a/syncgroup.go +++ b/syncgroup.go @@ -8,9 +8,9 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol" - "github.com/segmentio/kafka-go/protocol/consumer" - "github.com/segmentio/kafka-go/protocol/syncgroup" + "github.com/generalmotors/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol/consumer" + "github.com/generalmotors/kafka-go/protocol/syncgroup" ) // SyncGroupRequest is the request structure for the SyncGroup function. diff --git a/topics/list_topics.go b/topics/list_topics.go index 432f59d31..99c49bb0b 100644 --- a/topics/list_topics.go +++ b/topics/list_topics.go @@ -8,7 +8,7 @@ import ( "errors" "regexp" - "github.com/segmentio/kafka-go" + "github.com/generalmotors/kafka-go" ) // List returns a slice of all the Topics. diff --git a/topics/list_topics_test.go b/topics/list_topics_test.go index 2120c278a..8bd9562d7 100644 --- a/topics/list_topics_test.go +++ b/topics/list_topics_test.go @@ -7,8 +7,8 @@ import ( "testing" "time" - "github.com/segmentio/kafka-go" - ktesting "github.com/segmentio/kafka-go/testing" + "github.com/generalmotors/kafka-go" + ktesting "github.com/generalmotors/kafka-go/testing" ) func TestListReNil(t *testing.T) { diff --git a/transport.go b/transport.go index 685bdddb1..54ce27132 100644 --- a/transport.go +++ b/transport.go @@ -16,14 +16,14 @@ import ( "sync/atomic" "time" - "github.com/segmentio/kafka-go/protocol" - "github.com/segmentio/kafka-go/protocol/apiversions" - "github.com/segmentio/kafka-go/protocol/createtopics" - "github.com/segmentio/kafka-go/protocol/findcoordinator" - meta "github.com/segmentio/kafka-go/protocol/metadata" - "github.com/segmentio/kafka-go/protocol/saslauthenticate" - "github.com/segmentio/kafka-go/protocol/saslhandshake" - "github.com/segmentio/kafka-go/sasl" + "github.com/generalmotors/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol/apiversions" + "github.com/generalmotors/kafka-go/protocol/createtopics" + "github.com/generalmotors/kafka-go/protocol/findcoordinator" + meta "github.com/generalmotors/kafka-go/protocol/metadata" + "github.com/generalmotors/kafka-go/protocol/saslauthenticate" + "github.com/generalmotors/kafka-go/protocol/saslhandshake" + "github.com/generalmotors/kafka-go/sasl" ) // Request is an interface implemented by types that represent messages sent diff --git a/transport_test.go b/transport_test.go index eaae33291..5faf2a4ae 100644 --- a/transport_test.go +++ b/transport_test.go @@ -8,9 +8,9 @@ import ( "testing" "time" - "github.com/segmentio/kafka-go/protocol" - "github.com/segmentio/kafka-go/protocol/createtopics" - meta "github.com/segmentio/kafka-go/protocol/metadata" + "github.com/generalmotors/kafka-go/protocol" + "github.com/generalmotors/kafka-go/protocol/createtopics" + meta "github.com/generalmotors/kafka-go/protocol/metadata" ) func TestIssue477(t *testing.T) { diff --git a/txnoffsetcommit.go b/txnoffsetcommit.go index 9480fc3a7..521e19a1b 100644 --- a/txnoffsetcommit.go +++ b/txnoffsetcommit.go @@ -6,7 +6,7 @@ import ( "net" "time" - "github.com/segmentio/kafka-go/protocol/txnoffsetcommit" + "github.com/generalmotors/kafka-go/protocol/txnoffsetcommit" ) // TxnOffsetCommitRequest represents a request sent to a kafka broker to commit diff --git a/txnoffsetcommit_test.go b/txnoffsetcommit_test.go index eb3d33cbd..27360f010 100644 --- a/txnoffsetcommit_test.go +++ b/txnoffsetcommit_test.go @@ -8,7 +8,7 @@ import ( "testing" "time" - ktesting "github.com/segmentio/kafka-go/testing" + ktesting "github.com/generalmotors/kafka-go/testing" ) func TestClientTxnOffsetCommit(t *testing.T) { diff --git a/write_test.go b/write_test.go index a9f26e4af..4ec96608d 100644 --- a/write_test.go +++ b/write_test.go @@ -8,7 +8,7 @@ import ( "testing" "time" - ktesting "github.com/segmentio/kafka-go/testing" + ktesting "github.com/generalmotors/kafka-go/testing" ) const ( diff --git a/writer.go b/writer.go index 3817bf538..b4598724c 100644 --- a/writer.go +++ b/writer.go @@ -10,7 +10,7 @@ import ( "sync/atomic" "time" - metadataAPI "github.com/segmentio/kafka-go/protocol/metadata" + metadataAPI "github.com/generalmotors/kafka-go/protocol/metadata" ) // The Writer type provides the implementation of a producer of kafka messages diff --git a/writer_test.go b/writer_test.go index 6f894ecd3..50c128685 100644 --- a/writer_test.go +++ b/writer_test.go @@ -12,7 +12,7 @@ import ( "testing" "time" - "github.com/segmentio/kafka-go/sasl/plain" + "github.com/generalmotors/kafka-go/sasl/plain" ) func TestBatchQueue(t *testing.T) { diff --git a/zstd/zstd.go b/zstd/zstd.go index c8bded1c3..719b7a892 100644 --- a/zstd/zstd.go +++ b/zstd/zstd.go @@ -3,7 +3,7 @@ // codec, which is now always included. package zstd -import "github.com/segmentio/kafka-go/compress/zstd" +import "github.com/generalmotors/kafka-go/compress/zstd" const ( Code = 4