Fork (#4)

* Change module names to use generalmotors org
* Fixed imports

.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() {

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.

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) {

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

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) {

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

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"
 )
 

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.

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"
 )
 

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.

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) {

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

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) {

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.

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.

client.go

@@ -7,7 +7,7 @@ import (
 	"net"
 	"time"
 
-	"github.com/segmentio/kafka-go/protocol"
+	"github.com/generalmotors/kafka-go/protocol"
 )
 
 const (

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()) {

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.

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() {

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

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

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"
 )
 

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

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) {

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

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) {

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

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

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"
 )
 

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

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) {

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

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

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"
 )
 

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

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.

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"
 )
 

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.

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

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"
 )
 

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