diff --git a/.semaphore/semaphore.yml b/.semaphore/semaphore.yml index d2c0232ee..3850c7387 100644 --- a/.semaphore/semaphore.yml +++ b/.semaphore/semaphore.yml @@ -6,7 +6,7 @@ agent: global_job_config: env_vars: - name: LIBRDKAFKA_VERSION - value: v2.5.3 + value: v2.6.0-RC2 prologue: commands: - checkout diff --git a/README.md b/README.md index 2e246421e..3e1672edf 100644 --- a/README.md +++ b/README.md @@ -137,7 +137,7 @@ for use with [Confluent Cloud](https://www.confluent.io/confluent-cloud/). Getting Started =============== -Supports Go 1.17+ and librdkafka 2.5.3+. +Supports Go 1.17+ and librdkafka 2.6.0+. Using Go Modules ---------------- diff --git a/examples/docker_aws_lambda_example/go.mod b/examples/docker_aws_lambda_example/go.mod index a3a686695..ceb484cb9 100644 --- a/examples/docker_aws_lambda_example/go.mod +++ b/examples/docker_aws_lambda_example/go.mod @@ -2,7 +2,7 @@ module docker_example require ( github.com/aws/aws-lambda-go v1.27.0 - github.com/confluentinc/confluent-kafka-go/v2 v2.5.4 + github.com/confluentinc/confluent-kafka-go/v2 v2.6.0-RC2 ) go 1.21 diff --git a/examples/go.mod b/examples/go.mod index c3c7650c2..b33aaa35e 100644 --- a/examples/go.mod +++ b/examples/go.mod @@ -9,7 +9,7 @@ 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/confluentinc/confluent-kafka-go/v2 v2.5.4 + github.com/confluentinc/confluent-kafka-go/v2 v2.6.0-RC2 github.com/gdamore/tcell v1.4.0 google.golang.org/protobuf v1.33.0 ) diff --git a/kafka/00version.go b/kafka/00version.go index 4343f52df..a4e2cad24 100644 --- a/kafka/00version.go +++ b/kafka/00version.go @@ -29,19 +29,19 @@ import ( //defines and strings in sync. // -#define MIN_RD_KAFKA_VERSION 0x02050300 +#define MIN_RD_KAFKA_VERSION 0x02060000 #ifdef __APPLE__ -#define MIN_VER_ERRSTR "confluent-kafka-go requires librdkafka v2.5.3 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.6.0 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.5.3 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.6.0 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.5.3 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.6.0 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.5.3 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.6.0 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 156871261..2fc915574 100644 --- a/kafka/api.html +++ b/kafka/api.html @@ -14,7 +14,7 @@ @@ -1810,70 +1810,70 @@
- + 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 - + time.go @@ -1905,7 +1905,7 @@
LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client -
const LibrdkafkaLinkInfo = "static glibc_linux_amd64 from librdkafka-static-bundle-v2.5.3.tgz"
+ const LibrdkafkaLinkInfo = "static glibc_linux_amd64 from librdkafka-static-bundle-v2.6.0-RC2.tgz"
OffsetBeginning represents the earliest offset (logical)
const OffsetBeginning = Offset(C.RD_KAFKA_OFFSET_BEGINNING)
@@ -1924,7 +1924,7 @@ const PartitionAny = int32(C.RD_KAFKA_PARTITION_UA)
type ACLBindingFilter = ACLBinding
type ACLBindingFilters []ACLBindingFilter
type ACLBindings []ACLBinding
func (a ACLBindings) Len() int
func (a ACLBindings) Less(i, j int) bool
func (a ACLBindings) Swap(i, j int)
type AlterOperation int
func (e AssignedPartitions) String() string
type ConfigMap map[string]ConfigValue