librdkafka v2.3.0 (#1086)

confluentinc · Oct 25, 2023 · 5f88a1c · 5f88a1c
2 parents cd781ba + fc29e3d
commit 5f88a1c
Show file tree

Hide file tree

Showing 21 changed files with 345 additions and 343 deletions.
diff --git a/.semaphore/semaphore.yml b/.semaphore/semaphore.yml
@@ -6,7 +6,7 @@ agent:
 global_job_config:
   env_vars:
     - name: LIBRDKAFKA_VERSION
-      value: v2.3.0-RC4
+      value: v2.3.0
   prologue:
     commands:
       - checkout

diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -41,7 +41,7 @@ This is a feature release.
    consumer was closing, and during the final partition revoke (#1073).
 
 confluent-kafka-go is based on librdkafka v2.3.0, see the
-[librdkafka v2.3.0 release notes](https://github.com/confluentinc/librdkafka/releases/tag/v2.3.0-RC4)
+[librdkafka v2.3.0 release notes](https://github.com/confluentinc/librdkafka/releases/tag/v2.3.0)
 for a complete list of changes, enhancements, fixes and upgrade considerations.
 
 

diff --git a/examples/go.mod b/examples/go.mod
@@ -7,7 +7,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.3.0-RC4
+	github.com/confluentinc/confluent-kafka-go/v2 v2.3.0
 	github.com/gdamore/tcell v1.4.0
 	google.golang.org/protobuf v1.30.0
 )

diff --git a/kafka/api.html b/kafka/api.html
diff --git a/kafka/build_darwin_amd64.go b/kafka/build_darwin_amd64.go
@@ -10,4 +10,4 @@ package kafka
 import "C"
 
 // LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client
-const LibrdkafkaLinkInfo = "static darwin_amd64 from librdkafka-static-bundle-v2.3.0-RC4.tgz"
+const LibrdkafkaLinkInfo = "static darwin_amd64 from librdkafka-static-bundle-v2.3.0.tgz"
diff --git a/kafka/build_darwin_arm64.go b/kafka/build_darwin_arm64.go
@@ -10,4 +10,4 @@ package kafka
 import "C"
 
 // LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client
-const LibrdkafkaLinkInfo = "static darwin_arm64 from librdkafka-static-bundle-v2.3.0-RC4.tgz"
+const LibrdkafkaLinkInfo = "static darwin_arm64 from librdkafka-static-bundle-v2.3.0.tgz"
diff --git a/kafka/build_glibc_linux_amd64.go b/kafka/build_glibc_linux_amd64.go
@@ -10,4 +10,4 @@ package kafka
 import "C"
 
 // LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client
-const LibrdkafkaLinkInfo = "static glibc_linux_amd64 from librdkafka-static-bundle-v2.3.0-RC4.tgz"
+const LibrdkafkaLinkInfo = "static glibc_linux_amd64 from librdkafka-static-bundle-v2.3.0.tgz"
diff --git a/kafka/build_glibc_linux_arm64.go b/kafka/build_glibc_linux_arm64.go
@@ -10,4 +10,4 @@ package kafka
 import "C"
 
 // LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client
-const LibrdkafkaLinkInfo = "static glibc_linux_arm64 from librdkafka-static-bundle-v2.3.0-RC4.tgz"
+const LibrdkafkaLinkInfo = "static glibc_linux_arm64 from librdkafka-static-bundle-v2.3.0.tgz"
diff --git a/kafka/build_musl_linux_amd64.go b/kafka/build_musl_linux_amd64.go
@@ -10,4 +10,4 @@ package kafka
 import "C"
 
 // LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client
-const LibrdkafkaLinkInfo = "static musl_linux_amd64 from librdkafka-static-bundle-v2.3.0-RC4.tgz"
+const LibrdkafkaLinkInfo = "static musl_linux_amd64 from librdkafka-static-bundle-v2.3.0.tgz"
diff --git a/kafka/build_musl_linux_arm64.go b/kafka/build_musl_linux_arm64.go
@@ -10,4 +10,4 @@ package kafka
 import "C"
 
 // LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client
-const LibrdkafkaLinkInfo = "static musl_linux_arm64 from librdkafka-static-bundle-v2.3.0-RC4.tgz"
+const LibrdkafkaLinkInfo = "static musl_linux_arm64 from librdkafka-static-bundle-v2.3.0.tgz"
diff --git a/kafka/build_windows.go b/kafka/build_windows.go
@@ -10,4 +10,4 @@ package kafka
 import "C"
 
 // LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client
-const LibrdkafkaLinkInfo = "static windows from librdkafka-static-bundle-v2.3.0-RC4.tgz"
+const LibrdkafkaLinkInfo = "static windows from librdkafka-static-bundle-v2.3.0.tgz"
diff --git a/kafka/generated_errors.go b/kafka/generated_errors.go
@@ -1,7 +1,7 @@
 package kafka
 
 // Copyright 2016-2023 Confluent Inc.
-// AUTOMATICALLY GENERATED ON 2023-10-24 22:14:56.060860367 +0200 CEST m=+0.000525220 USING librdkafka 2.3.0-RC4
+// AUTOMATICALLY GENERATED ON 2023-10-25 15:32:05.267754826 +0200 CEST m=+0.000622161 USING librdkafka 2.3.0
 
 /*
 #include "select_rdkafka.h"

diff --git a/kafka/librdkafka_vendor/librdkafka_darwin_amd64.a b/kafka/librdkafka_vendor/librdkafka_darwin_amd64.a
diff --git a/kafka/librdkafka_vendor/librdkafka_darwin_arm64.a b/kafka/librdkafka_vendor/librdkafka_darwin_arm64.a
diff --git a/kafka/librdkafka_vendor/librdkafka_glibc_linux_amd64.a b/kafka/librdkafka_vendor/librdkafka_glibc_linux_amd64.a
diff --git a/kafka/librdkafka_vendor/librdkafka_glibc_linux_arm64.a b/kafka/librdkafka_vendor/librdkafka_glibc_linux_arm64.a
diff --git a/kafka/librdkafka_vendor/librdkafka_musl_linux_amd64.a b/kafka/librdkafka_vendor/librdkafka_musl_linux_amd64.a
diff --git a/kafka/librdkafka_vendor/librdkafka_musl_linux_arm64.a b/kafka/librdkafka_vendor/librdkafka_musl_linux_arm64.a
diff --git a/mk/doc-gen.py b/mk/doc-gen.py
@@ -24,7 +24,7 @@ def convert_path(url, base_url, after):
         sys.exit(1)
     package = sys.argv[1]
 
-    tag = "v2.3.0-RC4"
+    tag = "v2.3.0"
     major = tag.split(".")[0] # e.g. v2
     base_css = "https://go.dev/css"
     base_js = "https://go.dev/js"

diff --git a/schemaregistry/api.html b/schemaregistry/api.html
@@ -205,19 +205,19 @@ <h3>
       </h3>
       <p>
        <span style="font-size:90%">
-        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/config.go">
+        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/config.go">
          config.go
         </a>
-        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/mock_schemaregistry_client.go">
+        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/mock_schemaregistry_client.go">
          mock_schemaregistry_client.go
         </a>
-        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/rest_service.go">
+        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/rest_service.go">
          rest_service.go
         </a>
-        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/schemaregistry_client.go">
+        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/schemaregistry_client.go">
          schemaregistry_client.go
         </a>
-        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/testhelpers.go">
+        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/testhelpers.go">
          testhelpers.go
         </a>
        </span>
@@ -248,7 +248,7 @@ <h2 id="pkg-constants">
 )</pre>
     <h2 id="Client">
      type
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/schemaregistry_client.go?s=6616:7766#L189">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/schemaregistry_client.go?s=6616:7766#L189">
       Client
      </a>
      <a class="permalink" href="#Client">
@@ -281,7 +281,7 @@ <h2 id="Client">
 }</pre>
     <h3 id="NewClient">
      func
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/schemaregistry_client.go?s=7813:7857#L208">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/schemaregistry_client.go?s=7813:7857#L208">
       NewClient
      </a>
      <a class="permalink" href="#NewClient">
@@ -294,7 +294,7 @@ <h3 id="NewClient">
     </p>
     <h2 id="Compatibility">
      type
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/schemaregistry_client.go?s=18450:18472#L561">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/schemaregistry_client.go?s=18450:18472#L561">
       Compatibility
      </a>
      <a class="permalink" href="#Compatibility">
@@ -307,7 +307,7 @@ <h2 id="Compatibility">
     <pre>type Compatibility <a href="https://pkg.go.dev/builtin/#int">int</a></pre>
     <h3 id="Compatibility.MarshalJSON">
      func (Compatibility)
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/schemaregistry_client.go?s=19227:19279#L599">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/schemaregistry_client.go?s=19227:19279#L599">
       MarshalJSON
      </a>
      <a class="permalink" href="#Compatibility.MarshalJSON">
@@ -320,7 +320,7 @@ <h3 id="Compatibility.MarshalJSON">
     </p>
     <h3 id="Compatibility.ParseString">
      func (*Compatibility)
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/schemaregistry_client.go?s=19700:19753#L618">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/schemaregistry_client.go?s=19700:19753#L618">
       ParseString
      </a>
      <a class="permalink" href="#Compatibility.ParseString">
@@ -333,7 +333,7 @@ <h3 id="Compatibility.ParseString">
     </p>
     <h3 id="Compatibility.String">
      func (Compatibility)
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/schemaregistry_client.go?s=19567:19605#L613">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/schemaregistry_client.go?s=19567:19605#L613">
       String
      </a>
      <a class="permalink" href="#Compatibility.String">
@@ -343,7 +343,7 @@ <h3 id="Compatibility.String">
     <pre>func (c <a href="#Compatibility">Compatibility</a>) String() <a href="https://pkg.go.dev/builtin/#string">string</a></pre>
     <h3 id="Compatibility.UnmarshalJSON">
      func (*Compatibility)
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/schemaregistry_client.go?s=19363:19416#L604">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/schemaregistry_client.go?s=19363:19416#L604">
       UnmarshalJSON
      </a>
      <a class="permalink" href="#Compatibility.UnmarshalJSON">
@@ -356,7 +356,7 @@ <h3 id="Compatibility.UnmarshalJSON">
     </p>
     <h2 id="Config">
      type
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/config.go?s=722:2038#L12">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/config.go?s=722:2038#L12">
       Config
      </a>
      <a class="permalink" href="#Config">
@@ -401,7 +401,7 @@ <h2 id="Config">
 </pre>
     <h3 id="NewConfig">
      func
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/config.go?s=2110:2144#L46">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/config.go?s=2110:2144#L46">
       NewConfig
      </a>
      <a class="permalink" href="#NewConfig">
@@ -414,7 +414,7 @@ <h3 id="NewConfig">
     </p>
     <h3 id="NewConfigWithAuthentication">
      func
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/config.go?s=2710:2796#L71">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/config.go?s=2710:2796#L71">
       NewConfigWithAuthentication
      </a>
      <a class="permalink" href="#NewConfigWithAuthentication">
@@ -428,7 +428,7 @@ <h3 id="NewConfigWithAuthentication">
     </p>
     <h2 id="Reference">
      type
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/schemaregistry_client.go?s=3024:3145#L60">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/schemaregistry_client.go?s=3024:3145#L60">
       Reference
      </a>
      <a class="permalink" href="#Reference">
@@ -446,7 +446,7 @@ <h2 id="Reference">
 </pre>
     <h2 id="RestError">
      type
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/rest_service.go?s=2572:2666#L84">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/rest_service.go?s=2572:2666#L84">
       RestError
      </a>
      <a class="permalink" href="#RestError">
@@ -463,7 +463,7 @@ <h2 id="RestError">
 </pre>
     <h3 id="RestError.Error">
      func (*RestError)
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/rest_service.go?s=2715:2751#L90">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/rest_service.go?s=2715:2751#L90">
       Error
      </a>
      <a class="permalink" href="#RestError.Error">
@@ -476,7 +476,7 @@ <h3 id="RestError.Error">
     </p>
     <h2 id="SchemaInfo">
      type
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/schemaregistry_client.go?s=3197:3381#L67">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/schemaregistry_client.go?s=3197:3381#L67">
       SchemaInfo
      </a>
      <a class="permalink" href="#SchemaInfo">
@@ -494,7 +494,7 @@ <h2 id="SchemaInfo">
 </pre>
     <h3 id="SchemaInfo.MarshalJSON">
      func (*SchemaInfo)
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/schemaregistry_client.go?s=3438:3489#L74">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/schemaregistry_client.go?s=3438:3489#L74">
       MarshalJSON
      </a>
      <a class="permalink" href="#SchemaInfo.MarshalJSON">
@@ -507,7 +507,7 @@ <h3 id="SchemaInfo.MarshalJSON">
     </p>
     <h3 id="SchemaInfo.UnmarshalJSON">
      func (*SchemaInfo)
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/schemaregistry_client.go?s=3802:3853#L87">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/schemaregistry_client.go?s=3802:3853#L87">
       UnmarshalJSON
      </a>
      <a class="permalink" href="#SchemaInfo.UnmarshalJSON">
@@ -520,7 +520,7 @@ <h3 id="SchemaInfo.UnmarshalJSON">
     </p>
     <h2 id="SchemaMetadata">
      type
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/schemaregistry_client.go?s=4235:4401#L105">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/schemaregistry_client.go?s=4235:4401#L105">
       SchemaMetadata
      </a>
      <a class="permalink" href="#SchemaMetadata">
@@ -539,7 +539,7 @@ <h2 id="SchemaMetadata">
 </pre>
     <h3 id="SchemaMetadata.MarshalJSON">
      func (*SchemaMetadata)
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/schemaregistry_client.go?s=4458:4513#L113">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/schemaregistry_client.go?s=4458:4513#L113">
       MarshalJSON
      </a>
      <a class="permalink" href="#SchemaMetadata.MarshalJSON">
@@ -552,7 +552,7 @@ <h3 id="SchemaMetadata.MarshalJSON">
     </p>
     <h3 id="SchemaMetadata.UnmarshalJSON">
      func (*SchemaMetadata)
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0-RC4/schemaregistry/schemaregistry_client.go?s=5014:5069#L132">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.3.0/schemaregistry/schemaregistry_client.go?s=5014:5069#L132">
       UnmarshalJSON
      </a>
      <a class="permalink" href="#SchemaMetadata.UnmarshalJSON">

diff --git a/soaktest/go.mod b/soaktest/go.mod
@@ -7,7 +7,7 @@ replace github.com/confluentinc/confluent-kafka-go/v2 => ../
 require (
 	github.com/DataDog/datadog-go v4.8.3+incompatible
 	github.com/Microsoft/go-winio v0.6.0 // indirect
-	github.com/confluentinc/confluent-kafka-go/v2 v2.3.0-RC4
+	github.com/confluentinc/confluent-kafka-go/v2 v2.3.0
 	github.com/shirou/gopsutil v3.21.11+incompatible
 	github.com/tklauser/go-sysconf v0.3.11 // indirect
 	github.com/yusufpapurcu/wmi v1.2.2 // indirect