From cde2827bc49655eca0f9ce3fc1cda13cb6cdabc9 Mon Sep 17 00:00:00 2001 From: Milind L Date: Mon, 23 Jan 2023 14:55:02 +0530 Subject: [PATCH] Change go module for v2 (#931) Update go.mod of all the modules Update imports across files Ran go mod tidy which generated the go.sum files. Documentation update, needed to change the generate script as well for v2. Documentation changes in README.md Co-authored-by: Emanuele Sabellico --- CHANGELOG.md | 9 +- README.md | 12 +- .../admin_alter_consumer_group_offsets.go | 2 +- .../admin_create_acls/admin_create_acls.go | 2 +- .../admin_create_topic/admin_create_topic.go | 2 +- .../admin_delete_acls/admin_delete_acls.go | 2 +- .../admin_delete_consumer_groups.go | 2 +- .../admin_delete_topics.go | 2 +- .../admin_describe_acls.go | 2 +- .../admin_describe_config.go | 2 +- .../admin_describe_consumer_groups.go | 2 +- .../admin_list_consumer_group_offsets.go | 2 +- .../admin_list_consumer_groups.go | 2 +- .../avro_generic_consumer_example.go | 8 +- .../avro_generic_producer_example.go | 8 +- .../avro_specific_consumer_example.go | 8 +- .../avro_specific_producer_example.go | 8 +- .../confluent_cloud_example.go | 8 +- examples/consumer_example/consumer_example.go | 2 +- .../consumer_offset_metadata.go | 2 +- .../cooperative_consumer_example.go | 2 +- .../producer_example.go | 2 +- examples/go-kafkacat/go-kafkacat.go | 2 +- examples/go.mod | 8 +- examples/go.sum | 1 - .../idempotent_producer_example.go | 2 +- .../json_consumer_example.go | 8 +- .../json_producer_example.go | 8 +- .../consumer_channel_example.go | 2 +- .../producer_channel_example.go | 2 +- examples/library-version/library-version.go | 2 +- examples/mockcluster_example/mockcluster.go | 2 +- .../oauthbearer_consumer_example.go | 2 +- .../oauthbearer_oidc_example.go | 2 +- .../oauthbearer_producer_example.go | 2 +- .../producer_custom_channel_example.go | 2 +- examples/producer_example/producer_example.go | 2 +- .../protobuf_consumer_example.go | 8 +- .../protobuf_producer_example.go | 8 +- examples/stats_example/stats_example.go | 2 +- examples/transactions_example/generator.go | 2 +- examples/transactions_example/processor.go | 2 +- .../transactions_example.go | 2 +- examples/transactions_example/txnhelpers.go | 2 +- examples/transactions_example/visualizer.go | 2 +- go.mod | 5 +- go.sum | 11 +- kafka/00version.go | 10 +- kafka/api.html | 514 +++++++++--------- kafka/generated_errors.go | 2 +- kafka/go_rdkafka_generr/go_rdkafka_generr.go | 2 +- kafka/kafka.go | 2 +- kafkatest/go.mod | 9 +- kafkatest/go.sum | 212 +++++++- .../go_verifiable_consumer.go | 2 +- .../go_verifiable_producer.go | 2 +- mk/doc-gen.py | 8 +- schemaregistry/api.html | 54 +- schemaregistry/schemaregistry_client.go | 2 +- schemaregistry/serde/avro/avro.go | 2 +- schemaregistry/serde/avro/avro_generic.go | 4 +- .../serde/avro/avro_generic_test.go | 6 +- schemaregistry/serde/avro/avro_specific.go | 4 +- .../serde/avro/avro_specific_test.go | 6 +- schemaregistry/serde/avro/config.go | 2 +- schemaregistry/serde/jsonschema/config.go | 2 +- .../serde/jsonschema/json_schema.go | 4 +- .../serde/jsonschema/json_schema_test.go | 6 +- schemaregistry/serde/protobuf/config.go | 2 +- schemaregistry/serde/protobuf/protobuf.go | 8 +- .../serde/protobuf/protobuf_test.go | 6 +- schemaregistry/serde/serde.go | 2 +- soaktest/go.mod | 16 +- soaktest/go.sum | 250 ++++++++- soaktest/soakclient/soakclient.go | 4 +- .../soakclient_transaction.go | 4 +- soaktest/soaktest.go | 2 +- 77 files changed, 874 insertions(+), 457 deletions(-) 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