diff --git a/CHANGELOG.md b/CHANGELOG.md index c75378d10..b53f10263 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,6 +1,6 @@ # Confluent's Golang client for Apache Kafka -## v2.0.0 +## v2.0.2 This is a feature release: @@ -43,11 +43,14 @@ This is a feature release: (@HansK-p, @ju-popov, #878). -confluent-kafka-go is based on librdkafka v2.0.0, see the -[librdkafka release notes](https://github.com/confluentinc/librdkafka/releases/tag/v2.0.0) +confluent-kafka-go is based on librdkafka v2.0.2, see the +[librdkafka release notes](https://github.com/confluentinc/librdkafka/releases/tag/v2.0.2) for a complete list of changes, enhancements, fixes and upgrade considerations. +**Note**: There were no confluent-kafka-go v2.0.0 or v2.0.1 releases. + + ## v1.9.2 This is a maintenance release: diff --git a/README.md b/README.md index dfa85bdc7..52436ef7b 100644 --- a/README.md +++ b/README.md @@ -44,7 +44,7 @@ import ( "fmt" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { @@ -85,7 +85,7 @@ Producer ```golang import ( "fmt" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { @@ -133,7 +133,7 @@ for use with [Confluent Cloud](https://www.confluent.io/confluent-cloud/). Getting Started =============== -Supports Go 1.14+ and librdkafka 2.0.0+. +Supports Go 1.14+ and librdkafka 2.0.2+. Using Go Modules ---------------- @@ -144,7 +144,7 @@ confluent-kafka-go. Import the `kafka` package from GitHub in your code: ```golang -import "github.com/confluentinc/confluent-kafka-go/kafka" +import "github.com/confluentinc/confluent-kafka-go/v2/kafka" ``` Build your project: @@ -167,12 +167,12 @@ Install the client Manual install: ```bash -go get -u github.com/confluentinc/confluent-kafka-go/kafka +go get -u github.com/confluentinc/confluent-kafka-go/v2/kafka ``` Golang import: ```golang -import "github.com/confluentinc/confluent-kafka-go/kafka" +import "github.com/confluentinc/confluent-kafka-go/v2/kafka" ``` librdkafka diff --git a/examples/admin_alter_consumer_group_offsets/admin_alter_consumer_group_offsets.go b/examples/admin_alter_consumer_group_offsets/admin_alter_consumer_group_offsets.go index 2a18dbcc6..43fe243d6 100644 --- a/examples/admin_alter_consumer_group_offsets/admin_alter_consumer_group_offsets.go +++ b/examples/admin_alter_consumer_group_offsets/admin_alter_consumer_group_offsets.go @@ -24,7 +24,7 @@ import ( "strconv" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { diff --git a/examples/admin_create_acls/admin_create_acls.go b/examples/admin_create_acls/admin_create_acls.go index e827e3339..ee716a478 100644 --- a/examples/admin_create_acls/admin_create_acls.go +++ b/examples/admin_create_acls/admin_create_acls.go @@ -23,7 +23,7 @@ import ( "os" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) // Parses a list of 7n arguments to a slice of n ACLBinding diff --git a/examples/admin_create_topic/admin_create_topic.go b/examples/admin_create_topic/admin_create_topic.go index 301696872..f5ed6591e 100644 --- a/examples/admin_create_topic/admin_create_topic.go +++ b/examples/admin_create_topic/admin_create_topic.go @@ -24,7 +24,7 @@ import ( "strconv" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { diff --git a/examples/admin_delete_acls/admin_delete_acls.go b/examples/admin_delete_acls/admin_delete_acls.go index e87b6c8ab..26f3d5403 100644 --- a/examples/admin_delete_acls/admin_delete_acls.go +++ b/examples/admin_delete_acls/admin_delete_acls.go @@ -23,7 +23,7 @@ import ( "os" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) // Parses a list of 7n arguments to a slice of n ACLBindingFilter diff --git a/examples/admin_delete_consumer_groups/admin_delete_consumer_groups.go b/examples/admin_delete_consumer_groups/admin_delete_consumer_groups.go index 0dcc2dd8e..48838a438 100644 --- a/examples/admin_delete_consumer_groups/admin_delete_consumer_groups.go +++ b/examples/admin_delete_consumer_groups/admin_delete_consumer_groups.go @@ -24,7 +24,7 @@ import ( "strconv" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { diff --git a/examples/admin_delete_topics/admin_delete_topics.go b/examples/admin_delete_topics/admin_delete_topics.go index 1613adbbc..91512d8fd 100644 --- a/examples/admin_delete_topics/admin_delete_topics.go +++ b/examples/admin_delete_topics/admin_delete_topics.go @@ -23,7 +23,7 @@ import ( "os" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { diff --git a/examples/admin_describe_acls/admin_describe_acls.go b/examples/admin_describe_acls/admin_describe_acls.go index 6fc055d47..8ffcdfd04 100644 --- a/examples/admin_describe_acls/admin_describe_acls.go +++ b/examples/admin_describe_acls/admin_describe_acls.go @@ -23,7 +23,7 @@ import ( "os" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) // Parses a list of 7n arguments to a slice of n ACLBindingFilter diff --git a/examples/admin_describe_config/admin_describe_config.go b/examples/admin_describe_config/admin_describe_config.go index 3dbe32e72..0ad359eff 100644 --- a/examples/admin_describe_config/admin_describe_config.go +++ b/examples/admin_describe_config/admin_describe_config.go @@ -23,7 +23,7 @@ import ( "os" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { diff --git a/examples/admin_describe_consumer_groups/admin_describe_consumer_groups.go b/examples/admin_describe_consumer_groups/admin_describe_consumer_groups.go index abee0c4df..2a0852e53 100644 --- a/examples/admin_describe_consumer_groups/admin_describe_consumer_groups.go +++ b/examples/admin_describe_consumer_groups/admin_describe_consumer_groups.go @@ -23,7 +23,7 @@ import ( "os" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { diff --git a/examples/admin_list_consumer_group_offsets/admin_list_consumer_group_offsets.go b/examples/admin_list_consumer_group_offsets/admin_list_consumer_group_offsets.go index 71657eade..1f8b7419b 100644 --- a/examples/admin_list_consumer_group_offsets/admin_list_consumer_group_offsets.go +++ b/examples/admin_list_consumer_group_offsets/admin_list_consumer_group_offsets.go @@ -24,7 +24,7 @@ import ( "strconv" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { diff --git a/examples/admin_list_consumer_groups/admin_list_consumer_groups.go b/examples/admin_list_consumer_groups/admin_list_consumer_groups.go index bd606b199..f3bf7e198 100644 --- a/examples/admin_list_consumer_groups/admin_list_consumer_groups.go +++ b/examples/admin_list_consumer_groups/admin_list_consumer_groups.go @@ -23,7 +23,7 @@ import ( "os" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { diff --git a/examples/avro_generic_consumer_example/avro_generic_consumer_example.go b/examples/avro_generic_consumer_example/avro_generic_consumer_example.go index c8d7315ff..15ac403a4 100644 --- a/examples/avro_generic_consumer_example/avro_generic_consumer_example.go +++ b/examples/avro_generic_consumer_example/avro_generic_consumer_example.go @@ -26,10 +26,10 @@ import ( "os/signal" "syscall" - "github.com/confluentinc/confluent-kafka-go/kafka" - "github.com/confluentinc/confluent-kafka-go/schemaregistry" - "github.com/confluentinc/confluent-kafka-go/schemaregistry/serde" - "github.com/confluentinc/confluent-kafka-go/schemaregistry/serde/avro" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/avro" ) func main() { diff --git a/examples/avro_generic_producer_example/avro_generic_producer_example.go b/examples/avro_generic_producer_example/avro_generic_producer_example.go index e14ffdfea..9d9b45462 100644 --- a/examples/avro_generic_producer_example/avro_generic_producer_example.go +++ b/examples/avro_generic_producer_example/avro_generic_producer_example.go @@ -21,10 +21,10 @@ import ( "fmt" "os" - "github.com/confluentinc/confluent-kafka-go/kafka" - "github.com/confluentinc/confluent-kafka-go/schemaregistry" - "github.com/confluentinc/confluent-kafka-go/schemaregistry/serde" - "github.com/confluentinc/confluent-kafka-go/schemaregistry/serde/avro" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/avro" ) func main() { diff --git a/examples/avro_specific_consumer_example/avro_specific_consumer_example.go b/examples/avro_specific_consumer_example/avro_specific_consumer_example.go index 2e94afd3e..47e277596 100644 --- a/examples/avro_specific_consumer_example/avro_specific_consumer_example.go +++ b/examples/avro_specific_consumer_example/avro_specific_consumer_example.go @@ -26,10 +26,10 @@ import ( "os/signal" "syscall" - "github.com/confluentinc/confluent-kafka-go/kafka" - "github.com/confluentinc/confluent-kafka-go/schemaregistry" - "github.com/confluentinc/confluent-kafka-go/schemaregistry/serde" - "github.com/confluentinc/confluent-kafka-go/schemaregistry/serde/avro" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/avro" ) func main() { diff --git a/examples/avro_specific_producer_example/avro_specific_producer_example.go b/examples/avro_specific_producer_example/avro_specific_producer_example.go index dbbe4fe0c..df40f642c 100644 --- a/examples/avro_specific_producer_example/avro_specific_producer_example.go +++ b/examples/avro_specific_producer_example/avro_specific_producer_example.go @@ -21,10 +21,10 @@ import ( "fmt" "os" - "github.com/confluentinc/confluent-kafka-go/kafka" - "github.com/confluentinc/confluent-kafka-go/schemaregistry" - "github.com/confluentinc/confluent-kafka-go/schemaregistry/serde" - "github.com/confluentinc/confluent-kafka-go/schemaregistry/serde/avro" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/avro" ) func main() { diff --git a/examples/confluent_cloud_example/confluent_cloud_example.go b/examples/confluent_cloud_example/confluent_cloud_example.go index 5e1b7321c..4c154332d 100644 --- a/examples/confluent_cloud_example/confluent_cloud_example.go +++ b/examples/confluent_cloud_example/confluent_cloud_example.go @@ -29,10 +29,10 @@ import ( "os" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" - "github.com/confluentinc/confluent-kafka-go/schemaregistry" - "github.com/confluentinc/confluent-kafka-go/schemaregistry/serde" - "github.com/confluentinc/confluent-kafka-go/schemaregistry/serde/avro" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/avro" ) // In order to set the constants below, you are going to need diff --git a/examples/consumer_example/consumer_example.go b/examples/consumer_example/consumer_example.go index 569a75836..825211a4a 100644 --- a/examples/consumer_example/consumer_example.go +++ b/examples/consumer_example/consumer_example.go @@ -26,7 +26,7 @@ import ( "os/signal" "syscall" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { diff --git a/examples/consumer_offset_metadata/consumer_offset_metadata.go b/examples/consumer_offset_metadata/consumer_offset_metadata.go index 936532d41..64c69c9c2 100644 --- a/examples/consumer_offset_metadata/consumer_offset_metadata.go +++ b/examples/consumer_offset_metadata/consumer_offset_metadata.go @@ -26,7 +26,7 @@ import ( "os" "strconv" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { diff --git a/examples/cooperative_consumer_example/cooperative_consumer_example.go b/examples/cooperative_consumer_example/cooperative_consumer_example.go index 0ae113e09..35d053b28 100644 --- a/examples/cooperative_consumer_example/cooperative_consumer_example.go +++ b/examples/cooperative_consumer_example/cooperative_consumer_example.go @@ -25,7 +25,7 @@ import ( "os/signal" "syscall" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { diff --git a/examples/docker_aws_lambda_example/producer_example.go b/examples/docker_aws_lambda_example/producer_example.go index 6301fec96..419ae498d 100644 --- a/examples/docker_aws_lambda_example/producer_example.go +++ b/examples/docker_aws_lambda_example/producer_example.go @@ -26,7 +26,7 @@ import ( "os" "github.com/aws/aws-lambda-go/lambda" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) var p *kafka.Producer diff --git a/examples/go-kafkacat/go-kafkacat.go b/examples/go-kafkacat/go-kafkacat.go index 909fa72cf..d4c44f6cd 100644 --- a/examples/go-kafkacat/go-kafkacat.go +++ b/examples/go-kafkacat/go-kafkacat.go @@ -26,7 +26,7 @@ import ( "syscall" "github.com/alecthomas/kingpin" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) var ( diff --git a/examples/go.mod b/examples/go.mod index d328841c5..632e3ff05 100644 --- a/examples/go.mod +++ b/examples/go.mod @@ -1,15 +1,15 @@ -module github.com/confluentinc/confluent-kafka-go/examples +module github.com/confluentinc/confluent-kafka-go/examples/v2 -go 1.13 +go 1.14 -replace github.com/confluentinc/confluent-kafka-go => ../ +replace github.com/confluentinc/confluent-kafka-go/v2 => ../ require ( github.com/actgardner/gogen-avro/v10 v10.2.1 github.com/alecthomas/kingpin v2.2.6+incompatible github.com/alecthomas/template v0.0.0-20190718012654-fb15b899a751 // indirect github.com/alecthomas/units v0.0.0-20211218093645-b94a6e3cc137 // indirect - github.com/confluentinc/confluent-kafka-go v1.9.2 + github.com/confluentinc/confluent-kafka-go/v2 v2.0.2-00010101000000-000000000000 github.com/gdamore/tcell v1.4.0 google.golang.org/protobuf v1.28.0 ) diff --git a/examples/go.sum b/examples/go.sum index dddb1e9e1..611dde87e 100644 --- a/examples/go.sum +++ b/examples/go.sum @@ -167,7 +167,6 @@ golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJ golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= -golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= diff --git a/examples/idempotent_producer_example/idempotent_producer_example.go b/examples/idempotent_producer_example/idempotent_producer_example.go index 3ffbb8fea..0be0b38da 100644 --- a/examples/idempotent_producer_example/idempotent_producer_example.go +++ b/examples/idempotent_producer_example/idempotent_producer_example.go @@ -32,7 +32,7 @@ import ( "os" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) var run = true diff --git a/examples/json_consumer_example/json_consumer_example.go b/examples/json_consumer_example/json_consumer_example.go index 2e6f31612..ea864fbdb 100644 --- a/examples/json_consumer_example/json_consumer_example.go +++ b/examples/json_consumer_example/json_consumer_example.go @@ -26,10 +26,10 @@ import ( "os/signal" "syscall" - "github.com/confluentinc/confluent-kafka-go/kafka" - "github.com/confluentinc/confluent-kafka-go/schemaregistry" - "github.com/confluentinc/confluent-kafka-go/schemaregistry/serde" - "github.com/confluentinc/confluent-kafka-go/schemaregistry/serde/jsonschema" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/jsonschema" ) func main() { diff --git a/examples/json_producer_example/json_producer_example.go b/examples/json_producer_example/json_producer_example.go index eead1cbdb..474562b4e 100644 --- a/examples/json_producer_example/json_producer_example.go +++ b/examples/json_producer_example/json_producer_example.go @@ -21,10 +21,10 @@ import ( "fmt" "os" - "github.com/confluentinc/confluent-kafka-go/kafka" - "github.com/confluentinc/confluent-kafka-go/schemaregistry" - "github.com/confluentinc/confluent-kafka-go/schemaregistry/serde" - "github.com/confluentinc/confluent-kafka-go/schemaregistry/serde/jsonschema" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/jsonschema" ) func main() { diff --git a/examples/legacy/consumer_channel_example/consumer_channel_example.go b/examples/legacy/consumer_channel_example/consumer_channel_example.go index dfe7607a2..39842c290 100644 --- a/examples/legacy/consumer_channel_example/consumer_channel_example.go +++ b/examples/legacy/consumer_channel_example/consumer_channel_example.go @@ -23,7 +23,7 @@ import ( "os/signal" "syscall" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { diff --git a/examples/legacy/producer_channel_example/producer_channel_example.go b/examples/legacy/producer_channel_example/producer_channel_example.go index 367b0f4a5..9fbdddccb 100644 --- a/examples/legacy/producer_channel_example/producer_channel_example.go +++ b/examples/legacy/producer_channel_example/producer_channel_example.go @@ -21,7 +21,7 @@ import ( "fmt" "os" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { diff --git a/examples/library-version/library-version.go b/examples/library-version/library-version.go index 7a908254c..8b79a1216 100644 --- a/examples/library-version/library-version.go +++ b/examples/library-version/library-version.go @@ -22,7 +22,7 @@ package main import ( "fmt" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { diff --git a/examples/mockcluster_example/mockcluster.go b/examples/mockcluster_example/mockcluster.go index 149f766fa..9627b621b 100644 --- a/examples/mockcluster_example/mockcluster.go +++ b/examples/mockcluster_example/mockcluster.go @@ -20,7 +20,7 @@ import ( "fmt" "os" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { diff --git a/examples/oauthbearer_consumer_example/oauthbearer_consumer_example.go b/examples/oauthbearer_consumer_example/oauthbearer_consumer_example.go index c542c10c7..493c44667 100644 --- a/examples/oauthbearer_consumer_example/oauthbearer_consumer_example.go +++ b/examples/oauthbearer_consumer_example/oauthbearer_consumer_example.go @@ -27,7 +27,7 @@ import ( "syscall" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) var ( diff --git a/examples/oauthbearer_oidc_example/oauthbearer_oidc_example.go b/examples/oauthbearer_oidc_example/oauthbearer_oidc_example.go index 9e835e9f5..7c4afb083 100644 --- a/examples/oauthbearer_oidc_example/oauthbearer_oidc_example.go +++ b/examples/oauthbearer_oidc_example/oauthbearer_oidc_example.go @@ -30,7 +30,7 @@ import ( "syscall" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) const ( diff --git a/examples/oauthbearer_producer_example/oauthbearer_producer_example.go b/examples/oauthbearer_producer_example/oauthbearer_producer_example.go index 3e7b6e760..ef887d971 100644 --- a/examples/oauthbearer_producer_example/oauthbearer_producer_example.go +++ b/examples/oauthbearer_producer_example/oauthbearer_producer_example.go @@ -27,7 +27,7 @@ import ( "syscall" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) var ( diff --git a/examples/producer_custom_channel_example/producer_custom_channel_example.go b/examples/producer_custom_channel_example/producer_custom_channel_example.go index 9c9da1bdc..39f800488 100644 --- a/examples/producer_custom_channel_example/producer_custom_channel_example.go +++ b/examples/producer_custom_channel_example/producer_custom_channel_example.go @@ -22,7 +22,7 @@ import ( "os" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { diff --git a/examples/producer_example/producer_example.go b/examples/producer_example/producer_example.go index 1e1b43fe0..d486cb197 100644 --- a/examples/producer_example/producer_example.go +++ b/examples/producer_example/producer_example.go @@ -22,7 +22,7 @@ import ( "os" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { diff --git a/examples/protobuf_consumer_example/protobuf_consumer_example.go b/examples/protobuf_consumer_example/protobuf_consumer_example.go index 112f23057..536509aa9 100644 --- a/examples/protobuf_consumer_example/protobuf_consumer_example.go +++ b/examples/protobuf_consumer_example/protobuf_consumer_example.go @@ -26,10 +26,10 @@ import ( "os/signal" "syscall" - "github.com/confluentinc/confluent-kafka-go/kafka" - "github.com/confluentinc/confluent-kafka-go/schemaregistry" - "github.com/confluentinc/confluent-kafka-go/schemaregistry/serde" - "github.com/confluentinc/confluent-kafka-go/schemaregistry/serde/protobuf" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/protobuf" ) func main() { diff --git a/examples/protobuf_producer_example/protobuf_producer_example.go b/examples/protobuf_producer_example/protobuf_producer_example.go index 7ef792ba5..c6688c021 100644 --- a/examples/protobuf_producer_example/protobuf_producer_example.go +++ b/examples/protobuf_producer_example/protobuf_producer_example.go @@ -21,10 +21,10 @@ import ( "fmt" "os" - "github.com/confluentinc/confluent-kafka-go/kafka" - "github.com/confluentinc/confluent-kafka-go/schemaregistry" - "github.com/confluentinc/confluent-kafka-go/schemaregistry/serde" - "github.com/confluentinc/confluent-kafka-go/schemaregistry/serde/protobuf" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde" + "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/protobuf" ) func main() { diff --git a/examples/stats_example/stats_example.go b/examples/stats_example/stats_example.go index 08d32a08f..bb5bf18bb 100644 --- a/examples/stats_example/stats_example.go +++ b/examples/stats_example/stats_example.go @@ -28,7 +28,7 @@ import ( "os/signal" "syscall" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) func main() { diff --git a/examples/transactions_example/generator.go b/examples/transactions_example/generator.go index d2184da6c..7e80126c8 100644 --- a/examples/transactions_example/generator.go +++ b/examples/transactions_example/generator.go @@ -26,7 +26,7 @@ import ( "sync" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) // Intersections this application will process. diff --git a/examples/transactions_example/processor.go b/examples/transactions_example/processor.go index 495e01cfa..21f8ff218 100644 --- a/examples/transactions_example/processor.go +++ b/examples/transactions_example/processor.go @@ -27,7 +27,7 @@ import ( "sync" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) // The processor's consumer group id. diff --git a/examples/transactions_example/transactions_example.go b/examples/transactions_example/transactions_example.go index af1450cbe..98ae5b8b4 100644 --- a/examples/transactions_example/transactions_example.go +++ b/examples/transactions_example/transactions_example.go @@ -27,7 +27,7 @@ import ( "syscall" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) // Set to false to disable visualization, useful for troubleshooting. diff --git a/examples/transactions_example/txnhelpers.go b/examples/transactions_example/txnhelpers.go index 09de2c7f4..fe3be7c87 100644 --- a/examples/transactions_example/txnhelpers.go +++ b/examples/transactions_example/txnhelpers.go @@ -23,7 +23,7 @@ import ( "fmt" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" ) // createTransactionalProducer creates a transactional producer for the given diff --git a/examples/transactions_example/visualizer.go b/examples/transactions_example/visualizer.go index 04c8610ac..f6166e39e 100644 --- a/examples/transactions_example/visualizer.go +++ b/examples/transactions_example/visualizer.go @@ -28,7 +28,7 @@ import ( "sync" "time" - "github.com/confluentinc/confluent-kafka-go/kafka" + "github.com/confluentinc/confluent-kafka-go/v2/kafka" "github.com/gdamore/tcell" ) diff --git a/go.mod b/go.mod index 06da22041..cf8b4bd22 100644 --- a/go.mod +++ b/go.mod @@ -1,6 +1,6 @@ -module github.com/confluentinc/confluent-kafka-go +module github.com/confluentinc/confluent-kafka-go/v2 -go 1.13 +go 1.14 require ( github.com/actgardner/gogen-avro/v10 v10.2.1 @@ -9,7 +9,6 @@ require ( github.com/invopop/jsonschema v0.4.0 github.com/jhump/protoreflect v1.12.0 github.com/santhosh-tekuri/jsonschema/v5 v5.0.0 - golang.org/x/sync v0.0.0-20210220032951-036812b2e83c google.golang.org/genproto v0.0.0-20220503193339-ba3ae3f07e29 google.golang.org/protobuf v1.28.0 ) diff --git a/go.sum b/go.sum index 8d0f9bcd3..e182e88fc 100644 --- a/go.sum +++ b/go.sum @@ -48,7 +48,6 @@ github.com/golang/protobuf v1.4.0/go.mod h1:jodUvKwWbYaEsadDk5Fwe5c77LiNKVO9IDvq github.com/golang/protobuf v1.4.1/go.mod h1:U8fpvMrcmy5pZrNK1lt4xCsGvpyWQ/VVv6QDs8UjoX8= github.com/golang/protobuf v1.4.2/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI= github.com/golang/protobuf v1.4.3/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI= -github.com/golang/protobuf v1.5.0 h1:LUVKkCeviFUMKqHa4tXIIij/lbhnMbP7Fn5wKdKkRh4= github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk= github.com/golang/protobuf v1.5.2 h1:ROPKBNFfQgOUMifHyP+KYbvpjbdoFNs+aK7DXlji0Tw= github.com/golang/protobuf v1.5.2/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= @@ -130,7 +129,6 @@ golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPh golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA= golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE= golang.org/x/lint v0.0.0-20190227174305-5b3e6a55c961/go.mod h1:wehouNa3lNwaWXcvxsM5YxQ5yQlVC4a0KAMCusXpPoU= -golang.org/x/lint v0.0.0-20190313153728-d0100b6bd8b3 h1:XQyxROzUlZH+WIQwySDgnISgOivlhjIEwaQaJEJrrN0= golang.org/x/lint v0.0.0-20190313153728-d0100b6bd8b3/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc= golang.org/x/mod v0.2.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= @@ -142,7 +140,6 @@ golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= golang.org/x/net v0.0.0-20200226121028-0de0cce0169b/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= golang.org/x/net v0.0.0-20200505041828-1ed23360d12c/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A= -golang.org/x/net v0.0.0-20200625001655-4c5254603344 h1:vGXIOMxbNfDTk/aXCmfdLgkrSV+Z2tcbze+pEc3v5W4= golang.org/x/net v0.0.0-20200625001655-4c5254603344/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA= golang.org/x/net v0.0.0-20200822124328-c89045814202/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA= golang.org/x/net v0.0.0-20201021035429-f5854403a974/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU= @@ -155,8 +152,6 @@ golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJ golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= -golang.org/x/sync v0.0.0-20210220032951-036812b2e83c h1:5KslGYwFpkhGh+Q16bwMP3cOontH8FOep7tGV86Y7SQ= -golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= @@ -170,7 +165,6 @@ golang.org/x/sys v0.0.0-20211007075335-d3039528d8ac h1:oN6lz7iLW/YC7un8pq+9bOLyX golang.org/x/sys v0.0.0-20211007075335-d3039528d8ac/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= -golang.org/x/text v0.3.2 h1:tW2bmiBqwgJj/UpqtC8EpXEZVYOwU0yG4iWbprSVAcs= golang.org/x/text v0.3.2/go.mod h1:bEr9sfX3Q8Zfm5fL9x+3itogRgK3+ptLWKqgva+5dAk= golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= golang.org/x/text v0.3.5 h1:i6eZZ+zk0SOf0xgBpEpPD18qWcJda6q1sxt3S0kzyUQ= @@ -181,19 +175,17 @@ golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3 golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs= golang.org/x/tools v0.0.0-20190524140312-2c0ae7006135/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q= golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= -golang.org/x/tools v0.0.0-20200505023115-26f46d2f7ef8 h1:BMFHd4OFnFtWX46Xj4DN6vvT1btiBxyq+s0orYBqcQY= golang.org/x/tools v0.0.0-20200505023115-26f46d2f7ef8/go.mod h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE= golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= -golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4= golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= +golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 h1:go1bK/D/BFZV2I8cIQd1NKEZ+0owSTG1fDTci4IqFcE= golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= google.golang.org/appengine v1.1.0/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM= google.golang.org/appengine v1.4.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4= google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc= google.golang.org/genproto v0.0.0-20190819201941-24fa4b261c55/go.mod h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc= google.golang.org/genproto v0.0.0-20200513103714-09dca8ec2884/go.mod h1:55QSHmfGQM9UVYDPBsyGGes0y52j32PQ3BqQfXhyH3c= -google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013 h1:+kGHl1aib/qcwaRi1CbqBZ1rk19r85MNUf8HaBghugY= google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013/go.mod h1:NbSheEEYHJ7i3ixzK3sjbqSGDJWnxyFXZblF3eUsNvo= google.golang.org/genproto v0.0.0-20220503193339-ba3ae3f07e29 h1:DJUvgAPiJWeMBiT+RzBVcJGQN7bAEWS5UEoMshES9xs= google.golang.org/genproto v0.0.0-20220503193339-ba3ae3f07e29/go.mod h1:RAyBrSAP7Fh3Nc84ghnVLDPuV51xc9agzmm4Ph6i0Q4= @@ -203,7 +195,6 @@ google.golang.org/grpc v1.25.1/go.mod h1:c3i+UQWmh7LiEpx4sFZnkU36qjEYZ0imhYfXVyQ google.golang.org/grpc v1.27.0/go.mod h1:qbnxyOmOxrQa7FizSgH+ReBfzJrCY1pSN7KXBS8abTk= google.golang.org/grpc v1.33.1/go.mod h1:fr5YgcSWrqhRRxogOsw7RzIpsmvOZ6IcH4kBYTpR3n0= google.golang.org/grpc v1.36.0/go.mod h1:qjiiYl8FncCW8feJPdyg3v6XW24KsRHe+dy9BAGRRjU= -google.golang.org/grpc v1.38.0 h1:/9BgsAsa5nWe26HqOlvlgJnqBuktYOLCgjCPqsa56W0= google.golang.org/grpc v1.38.0/go.mod h1:NREThFqKR1f3iQ6oBuvc5LadQuXVGo9rkm5ZGrQdJfM= google.golang.org/grpc v1.46.0 h1:oCjezcn6g6A75TGoKYBPgKmVBLexhYLM6MebdrPApP8= google.golang.org/grpc v1.46.0/go.mod h1:vN9eftEi1UMyUsIF80+uQXhHjbXYbm0uXoFCACuMGWk= diff --git a/kafka/00version.go b/kafka/00version.go index d93816050..ac38d4e1f 100644 --- a/kafka/00version.go +++ b/kafka/00version.go @@ -29,19 +29,19 @@ import ( //defines and strings in sync. // -#define MIN_RD_KAFKA_VERSION 0x02000000 +#define MIN_RD_KAFKA_VERSION 0x02000200 #ifdef __APPLE__ -#define MIN_VER_ERRSTR "confluent-kafka-go requires librdkafka v2.0.0 or later. Install the latest version of librdkafka from Homebrew by running `brew install librdkafka` or `brew upgrade librdkafka`" +#define MIN_VER_ERRSTR "confluent-kafka-go requires librdkafka v2.0.2 or later. Install the latest version of librdkafka from Homebrew by running `brew install librdkafka` or `brew upgrade librdkafka`" #else -#define MIN_VER_ERRSTR "confluent-kafka-go requires librdkafka v2.0.0 or later. Install the latest version of librdkafka from the Confluent repositories, see http://docs.confluent.io/current/installation.html" +#define MIN_VER_ERRSTR "confluent-kafka-go requires librdkafka v2.0.2 or later. Install the latest version of librdkafka from the Confluent repositories, see http://docs.confluent.io/current/installation.html" #endif #if RD_KAFKA_VERSION < MIN_RD_KAFKA_VERSION #ifdef __APPLE__ -#error "confluent-kafka-go requires librdkafka v2.0.0 or later. Install the latest version of librdkafka from Homebrew by running `brew install librdkafka` or `brew upgrade librdkafka`" +#error "confluent-kafka-go requires librdkafka v2.0.2 or later. Install the latest version of librdkafka from Homebrew by running `brew install librdkafka` or `brew upgrade librdkafka`" #else -#error "confluent-kafka-go requires librdkafka v2.0.0 or later. Install the latest version of librdkafka from the Confluent repositories, see http://docs.confluent.io/current/installation.html" +#error "confluent-kafka-go requires librdkafka v2.0.2 or later. Install the latest version of librdkafka from the Confluent repositories, see http://docs.confluent.io/current/installation.html" #endif #endif */ diff --git a/kafka/api.html b/kafka/api.html index 32dc98d9b..4f4995d8d 100644 --- a/kafka/api.html +++ b/kafka/api.html @@ -14,7 +14,7 @@ @@ -52,7 +52,7 @@

- import "github.com/confluentinc/confluent-kafka-go/kafka" + import "github.com/confluentinc/confluent-kafka-go/v2/kafka"
@@ -1540,73 +1540,73 @@

- + 00version.go - + adminapi.go - + adminoptions.go - + build_glibc_linux_amd64.go - + config.go - + consumer.go - + context.go - + error.go - + error_gen.go - + event.go - + generated_errors.go - + handle.go - + header.go - + kafka.go - + log.go - + message.go - + metadata.go - + misc.go - + mockcluster.go - + offset.go - + producer.go - + testhelpers.go - + time.go @@ -1761,7 +1761,7 @@ 

const PartitionAny = int32(C.RD_KAFKA_PARTITION_UA)

func - + LibraryVersion

+ WriteErrorCodes

+ ACLBinding

+ ACLBindingFilter 

ACLBinding

type - + ACLBindingFilters 

ACLBindingFilter

type - + ACLBindings 

ACLBinding

func (ACLBindings) - + Len 

ACLBindings) Len() int

func (ACLBindings) - + Less 

ACLBindings) Less(i, j int) bool

func (ACLBindings) - + Swap 

ACLBindings) Swap(i, j int)

type - + ACLOperation 

int

func - + ACLOperationFromString

+ String

+ ACLPermissionType 

int

func - + ACLPermissionTypeFromString

+ String

+ AdminClient

+ NewAdminClient

+ NewAdminClientFromConsumer

+ NewAdminClientFromProducer

+ AlterConfigs

+ AlterConsumerGroupOffsets

+ Close

+ ClusterID

+ ControllerID

+ CreateACLs

+ CreatePartitions

+ CreateTopics

+ DeleteACLs

+ DeleteConsumerGroups

+ DeleteTopics

+ DescribeACLs

+ DescribeConfigs

+ DescribeConsumerGroups

+ GetMetadata

+ ListConsumerGroupOffsets

+ ListConsumerGroups

+ SetOAuthBearerToken

+ SetOAuthBearerTokenFailure

+ SetSaslCredentials

+ String

+ AdminOption

+ AdminOptionMatchConsumerGroupStates

+ SetAdminMatchConsumerGroupStates

+ AdminOptionOperationTimeout

+ SetAdminOperationTimeout

+ AdminOptionRequestTimeout

+ SetAdminRequestTimeout

+ AdminOptionRequireStableOffsets

+ SetAdminRequireStableOffsets

+ AdminOptionValidateOnly

+ SetAdminValidateOnly

+ AlterConfigsAdminOption

+ AlterConsumerGroupOffsetsAdminOption

+ AlterConsumerGroupOffsetsResult

+ AlterOperation 

int

func (AlterOperation) - + String

+ AssignedPartitions

+ String 

AssignedPartitions) String() string

type - + BrokerMetadata

+ ConfigEntry

+ StringMapToConfigEntries

+ String

+ ConfigEntryResult

+ String

+ ConfigMap 

string]ConfigValue

func (ConfigMap) - + Get

+ Set

+ SetKey

+ ConfigResource

+ String

+ ConfigResourceResult

+ String

+ ConfigSource 

int

func (ConfigSource) - + String

+ ConfigValue

+ Consumer

+ NewConsumer

+ Assign

+ Assignment

+ AssignmentLost

+ Close

+ Commit

+ CommitMessage

+ CommitOffsets

+ Committed

+ Events

+ GetConsumerGroupMetadata

+ GetMetadata

+ GetRebalanceProtocol

+ GetWatermarkOffsets

+ IncrementalAssign

+ IncrementalUnassign

+ Logs

+ OffsetsForTimes

+ Pause

+ Poll

+ Position

+ QueryWatermarkOffsets

+ ReadMessage

+ Resume

+ Seek

+ SetOAuthBearerToken

+ SetOAuthBearerTokenFailure

+ SetSaslCredentials

+ StoreMessage

+ StoreOffsets

+ String

+ Subscribe

+ SubscribeTopics

+ Subscription

+ Unassign

+ Unsubscribe

+ ConsumerGroupDescription

+ ConsumerGroupListing

+ ConsumerGroupMetadata

+ NewTestConsumerGroupMetadata

+ ConsumerGroupResult

+ String

+ ConsumerGroupState 

int

func - + ConsumerGroupStateFromString

+ String

+ ConsumerGroupTopicPartitions

+ String 

ConsumerGroupTopicPartitions) String() string

type - + CreateACLResult

+ CreateACLsAdminOption

+ CreatePartitionsAdminOption

+ CreateTopicsAdminOption

+ DeleteACLsAdminOption

+ DeleteACLsResult 

DescribeACLsResult

type - + DeleteConsumerGroupsAdminOption

+ DeleteConsumerGroupsResult

+ DeleteTopicsAdminOption

+ DescribeACLsAdminOption

+ DescribeACLsResult

+ DescribeConfigsAdminOption

+ DescribeConsumerGroupsAdminOption

+ DescribeConsumerGroupsResult

+ Error

+ NewError

+ Code

+ Error

+ IsFatal

+ IsRetriable

+ IsTimeout

+ String

+ TxnRequiresAbort

+ ErrorCode

+ String

+ Event

+ Handle