-
-
Notifications
You must be signed in to change notification settings - Fork 199
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
41 changed files
with
453 additions
and
417 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,17 +1,17 @@ | ||
| module admin_client | ||
|
|
||
| go 1.22 | ||
| go 1.23 | ||
|
|
||
| toolchain go1.22.0 | ||
| toolchain go1.23.3 | ||
|
|
||
| require ( | ||
| github.com/twmb/franz-go v1.16.1 | ||
| github.com/twmb/franz-go/pkg/kadm v1.11.0 | ||
| github.com/twmb/franz-go v1.18.0 | ||
| github.com/twmb/franz-go/pkg/kadm v1.14.0 | ||
| ) | ||
|
|
||
| require ( | ||
| github.com/klauspost/compress v1.17.8 // indirect | ||
| github.com/pierrec/lz4/v4 v4.1.21 // indirect | ||
| github.com/twmb/franz-go/pkg/kmsg v1.8.0 // indirect | ||
| golang.org/x/crypto v0.23.0 // indirect | ||
| github.com/klauspost/compress v1.17.11 // indirect | ||
| github.com/pierrec/lz4/v4 v4.1.22 // indirect | ||
| github.com/twmb/franz-go/pkg/kmsg v1.9.0 // indirect | ||
| golang.org/x/crypto v0.32.0 // indirect | ||
| ) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,12 +1,12 @@ | ||
| github.com/klauspost/compress v1.17.8 h1:YcnTYrq7MikUT7k0Yb5eceMmALQPYBW/Xltxn0NAMnU= | ||
| github.com/klauspost/compress v1.17.8/go.mod h1:Di0epgTjJY877eYKx5yC51cX2A2Vl2ibi7bDH9ttBbw= | ||
| github.com/pierrec/lz4/v4 v4.1.21 h1:yOVMLb6qSIDP67pl/5F7RepeKYu/VmTyEXvuMI5d9mQ= | ||
| github.com/pierrec/lz4/v4 v4.1.21/go.mod h1:gZWDp/Ze/IJXGXf23ltt2EXimqmTUXEy0GFuRQyBid4= | ||
| github.com/twmb/franz-go v1.16.1 h1:rpWc7fB9jd7TgmCyfxzenBI+QbgS8ZfJOUQE+tzPtbE= | ||
| github.com/twmb/franz-go v1.16.1/go.mod h1:/pER254UPPGp/4WfGqRi+SIRGE50RSQzVubQp6+N4FA= | ||
| github.com/twmb/franz-go/pkg/kadm v1.11.0 h1:FfeWJ0qadntFpAcQt8JzNXW4dijjytZNLrzJuzzzuxA= | ||
| github.com/twmb/franz-go/pkg/kadm v1.11.0/go.mod h1:qrhkdH+SWS3ivmbqOgHbpgVHamhaKcjH0UM+uOp0M1A= | ||
| github.com/twmb/franz-go/pkg/kmsg v1.8.0 h1:lAQB9Z3aMrIP9qF9288XcFf/ccaSxEitNA1CDTEIeTA= | ||
| github.com/twmb/franz-go/pkg/kmsg v1.8.0/go.mod h1:HzYEb8G3uu5XevZbtU0dVbkphaKTHk0X68N5ka4q6mU= | ||
| golang.org/x/crypto v0.23.0 h1:dIJU/v2J8Mdglj/8rJ6UUOM3Zc9zLZxVZwwxMooUSAI= | ||
| golang.org/x/crypto v0.23.0/go.mod h1:CKFgDieR+mRhux2Lsu27y0fO304Db0wZe70UKqHu0v8= | ||
| github.com/klauspost/compress v1.17.11 h1:In6xLpyWOi1+C7tXUUWv2ot1QvBjxevKAaI6IXrJmUc= | ||
| github.com/klauspost/compress v1.17.11/go.mod h1:pMDklpSncoRMuLFrf1W9Ss9KT+0rH90U12bZKk7uwG0= | ||
| github.com/pierrec/lz4/v4 v4.1.22 h1:cKFw6uJDK+/gfw5BcDL0JL5aBsAFdsIT18eRtLj7VIU= | ||
| github.com/pierrec/lz4/v4 v4.1.22/go.mod h1:gZWDp/Ze/IJXGXf23ltt2EXimqmTUXEy0GFuRQyBid4= | ||
| github.com/twmb/franz-go v1.18.0 h1:25FjMZfdozBywVX+5xrWC2W+W76i0xykKjTdEeD2ejw= | ||
| github.com/twmb/franz-go v1.18.0/go.mod h1:zXCGy74M0p5FbXsLeASdyvfLFsBvTubVqctIaa5wQ+I= | ||
| github.com/twmb/franz-go/pkg/kadm v1.14.0 h1:nAn1co1lXzJQocpzyIyOFOjUBf4WHWs5/fTprXy2IZs= | ||
| github.com/twmb/franz-go/pkg/kadm v1.14.0/go.mod h1:XjOPz6ZaXXjrW2jVCfLuucP8H1w2TvD6y3PT2M+aAM4= | ||
| github.com/twmb/franz-go/pkg/kmsg v1.9.0 h1:JojYUph2TKAau6SBtErXpXGC7E3gg4vGZMv9xFU/B6M= | ||
| github.com/twmb/franz-go/pkg/kmsg v1.9.0/go.mod h1:CMbfazviCyY6HM0SXuG5t9vOwYDHRCSrJJyBAe5paqg= | ||
| golang.org/x/crypto v0.32.0 h1:euUpcYgM8WcP71gNpTqQCn6rC2t6ULUPiOzfWaXVVfc= | ||
| golang.org/x/crypto v0.32.0/go.mod h1:ZnnJkOaASj8g0AjIduWNlq2NRxL0PlBrbKVyZ6V/Ugc= |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,7 +1,7 @@ | ||
| module ckg | ||
|
|
||
| go 1.22 | ||
| go 1.23 | ||
|
|
||
| toolchain go1.22.0 | ||
| toolchain go1.23.3 | ||
|
|
||
| require github.com/confluentinc/confluent-kafka-go v1.9.2 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,16 +1,16 @@ | ||
| module segment | ||
|
|
||
| go 1.22 | ||
| go 1.23 | ||
|
|
||
| toolchain go1.22.0 | ||
| toolchain go1.23.3 | ||
|
|
||
| require github.com/segmentio/kafka-go v0.4.47 | ||
|
|
||
| require ( | ||
| github.com/klauspost/compress v1.17.8 // indirect | ||
| github.com/pierrec/lz4/v4 v4.1.21 // indirect | ||
| github.com/klauspost/compress v1.17.11 // indirect | ||
| github.com/pierrec/lz4/v4 v4.1.22 // indirect | ||
| github.com/xdg-go/pbkdf2 v1.0.0 // indirect | ||
| github.com/xdg-go/scram v1.1.2 // indirect | ||
| github.com/xdg-go/stringprep v1.0.4 // indirect | ||
| golang.org/x/text v0.15.0 // indirect | ||
| golang.org/x/text v0.21.0 // indirect | ||
| ) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,26 +1,27 @@ | ||
| module bench | ||
|
|
||
| go 1.22 | ||
| go 1.23 | ||
|
|
||
| toolchain go1.22.0 | ||
| toolchain go1.23.3 | ||
|
|
||
| require ( | ||
| github.com/twmb/franz-go v1.16.1 | ||
| github.com/twmb/franz-go v1.18.0 | ||
| github.com/twmb/franz-go/plugin/kprom v1.1.0 | ||
| github.com/twmb/tlscfg v1.2.1 | ||
| ) | ||
|
|
||
| require ( | ||
| github.com/beorn7/perks v1.0.1 // indirect | ||
| github.com/cespare/xxhash/v2 v2.3.0 // indirect | ||
| github.com/klauspost/compress v1.17.8 // indirect | ||
| github.com/pierrec/lz4/v4 v4.1.21 // indirect | ||
| github.com/prometheus/client_golang v1.19.1 // indirect | ||
| github.com/klauspost/compress v1.17.11 // indirect | ||
| github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect | ||
| github.com/pierrec/lz4/v4 v4.1.22 // indirect | ||
| github.com/prometheus/client_golang v1.20.5 // indirect | ||
| github.com/prometheus/client_model v0.6.1 // indirect | ||
| github.com/prometheus/common v0.53.0 // indirect | ||
| github.com/prometheus/procfs v0.15.0 // indirect | ||
| github.com/twmb/franz-go/pkg/kmsg v1.8.0 // indirect | ||
| golang.org/x/crypto v0.23.0 // indirect | ||
| golang.org/x/sys v0.20.0 // indirect | ||
| google.golang.org/protobuf v1.34.1 // indirect | ||
| github.com/prometheus/common v0.62.0 // indirect | ||
| github.com/prometheus/procfs v0.15.1 // indirect | ||
| github.com/twmb/franz-go/pkg/kmsg v1.9.0 // indirect | ||
| golang.org/x/crypto v0.32.0 // indirect | ||
| golang.org/x/sys v0.29.0 // indirect | ||
| google.golang.org/protobuf v1.36.3 // indirect | ||
| ) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
12 changes: 6 additions & 6 deletions
12
examples/goroutine_per_partition_consuming/autocommit_marks/go.mod
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,13 +1,13 @@ | ||
| module goroutine_per_partition_consuming_autocommit_marks | ||
|
|
||
| go 1.22 | ||
| go 1.23 | ||
|
|
||
| toolchain go1.22.0 | ||
| toolchain go1.23.3 | ||
|
|
||
| require github.com/twmb/franz-go v1.16.1 | ||
| require github.com/twmb/franz-go v1.18.0 | ||
|
|
||
| require ( | ||
| github.com/klauspost/compress v1.17.8 // indirect | ||
| github.com/pierrec/lz4/v4 v4.1.21 // indirect | ||
| github.com/twmb/franz-go/pkg/kmsg v1.8.0 // indirect | ||
| github.com/klauspost/compress v1.17.11 // indirect | ||
| github.com/pierrec/lz4/v4 v4.1.22 // indirect | ||
| github.com/twmb/franz-go/pkg/kmsg v1.9.0 // indirect | ||
| ) |
Oops, something went wrong.