Run go mod tidy everywhere and add doc changes

CHANGELOG.md

@@ -1,5 +1,14 @@
 # Confluent's Golang client for Apache Kafka
 
+# v2.3.1
+
+This is a maintenance release.
+
+## Fixes
+
+ * The minimum version of Go supported has been changed from 1.17 to 1.21
+   (#1125, @rzeijde).
+
 
 # v2.3.0
 

README.md

@@ -133,7 +133,7 @@ for use with [Confluent Cloud](https://www.confluent.io/confluent-cloud/).
 Getting Started
 ===============
 
-Supports Go 1.17+ and librdkafka 2.2.0+.
+Supports Go 1.21+ and librdkafka 2.3.0+.
 
 Using Go Modules
 ----------------

examples/go.mod

@@ -26,6 +26,7 @@ require (
 	github.com/jhump/protoreflect v1.14.1 // indirect
 	github.com/lucasb-eyer/go-colorful v1.0.3 // indirect
 	github.com/mattn/go-runewidth v0.0.14 // indirect
+	github.com/rivo/uniseg v0.2.0 // indirect
 	github.com/santhosh-tekuri/jsonschema/v5 v5.2.0 // indirect
 	golang.org/x/sys v0.15.0 // indirect
 	golang.org/x/text v0.14.0 // indirect

kafka/README.md

@@ -2,7 +2,7 @@
 
 ## Development process
 
-1. Use go1.19 (and related tooling) for development on confluent-kafka-go.
+1. Use go1.21 (and related tooling) for development on confluent-kafka-go.
 2. Make sure to run `gofmt` and `go vet` on your code.
 3. While there is no hard-limit, try to keep your line length under 80
    characters.

kafka/integration_test.go

@@ -20,15 +20,16 @@ import (
 	"context"
 	"encoding/binary"
 	"fmt"
-	"github.com/stretchr/testify/suite"
-	"github.com/testcontainers/testcontainers-go/modules/compose"
 	"math/rand"
 	"path"
 	"reflect"
 	"runtime"
 	"sort"
 	"testing"
 	"time"
+
+	"github.com/stretchr/testify/suite"
+	"github.com/testcontainers/testcontainers-go/modules/compose"
 )
 
 // producer test control
@@ -521,7 +522,6 @@ func consumerTestWithCommits(t *testing.T, testname string, assignmentStrategy s
 		msgcnt, consumerCtrl{useChannel: useChannel, commitMode: ViaCommitOffsetsAPI}, consumeFunc, rebalanceCb)
 
 	consumerTest(t, testname+" using Commit() API", assignmentStrategy,
-
 		msgcnt, consumerCtrl{useChannel: useChannel, commitMode: ViaCommitAPI}, consumeFunc, rebalanceCb)
 
 }
@@ -3207,7 +3207,7 @@ func (its *IntegrationTestSuite) TestAdminClient_ListOffsets() {
 
 	for _, info := range results.ResultInfos {
 		assert.Equal(info.Error.Code(), ErrNoError, "Error code should be ErrNoError.")
-		assert.Equal(info.Offset, int64(0), "Offset should be ErrNoError.")
+		assert.Equal(info.Offset, Offset(0), "Offset should be 0.")
 	}
 
 	topicPartitionOffsets[tp1] = LatestOffsetSpec
@@ -3216,7 +3216,7 @@ func (its *IntegrationTestSuite) TestAdminClient_ListOffsets() {
 
 	for _, info := range results.ResultInfos {
 		assert.Equal(info.Error.Code(), ErrNoError, "Error code should be ErrNoError.")
-		assert.Equal(info.Offset, int64(3), "Offset should be 3.")
+		assert.Equal(info.Offset, Offset(3), "Offset should be 3.")
 	}
 
 	topicPartitionOffsets[tp1] = OffsetSpec(MaxTimestampOffsetSpec)
@@ -3225,7 +3225,7 @@ func (its *IntegrationTestSuite) TestAdminClient_ListOffsets() {
 
 	for _, info := range results.ResultInfos {
 		assert.Equal(info.Error.Code(), ErrNoError, "Error code should be ErrNoError.")
-		assert.Equal(info.Offset, int64(1), "Offset should be 1.")
+		assert.Equal(info.Offset, Offset(1), "Offset should be 1.")
 	}
 
 	delTopics := []string{Topic}

soaktest/go.mod

@@ -11,3 +11,15 @@ require (
 	github.com/confluentinc/confluent-kafka-go/v2 v2.3.0
 	github.com/shirou/gopsutil v3.21.11+incompatible
 )
+
+require (
+	github.com/Microsoft/go-winio v0.6.1 // indirect
+	github.com/go-ole/go-ole v1.2.6 // indirect
+	github.com/stretchr/objx v0.5.1 // indirect
+	github.com/tklauser/go-sysconf v0.3.12 // indirect
+	github.com/tklauser/numcpus v0.6.1 // indirect
+	github.com/yusufpapurcu/wmi v1.2.3 // indirect
+	golang.org/x/mod v0.11.0 // indirect
+	golang.org/x/sys v0.15.0 // indirect
+	golang.org/x/tools v0.10.0 // indirect
+)