librdkafka v2.4.0 (#1188)

milindl · web-flow · commit 1bb141db4d21 · 2024-05-07T16:51:07.000+05:30
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.4.0-RC2
+      value: v2.4.0
   prologue:
     commands:
       - checkout
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -4,8 +4,8 @@
 
 This is a feature release.
 
- * [KIP-848 EA](https://cwiki.apache.org/confluence/display/KAFKA/KIP-848%3A+The+Next+Generation+of+the+Consumer+Rebalance+Protocol):
-   Integration tests running with the new consumer group protocol. The feature is an Early Access: not production ready, still not supported (#1185).
+ * [KIP-848](https://cwiki.apache.org/confluence/display/KAFKA/KIP-848%3A+The+Next+Generation+of+the+Consumer+Rebalance+Protocol): 
+   Integration tests running with the new consumer group protocol. The feature is an **Early Access**: not production ready (#1185).
 
 ## Fixes
 
diff --git 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.4.0-RC2
+	github.com/confluentinc/confluent-kafka-go/v2 v2.4.0
 )
 
 go 1.14
diff --git 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.4.0-RC2
+	github.com/confluentinc/confluent-kafka-go/v2 v2.4.0
 	github.com/gdamore/tcell v1.4.0
 	google.golang.org/protobuf v1.33.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.4.0-RC2.tgz"
+const LibrdkafkaLinkInfo = "static darwin_amd64 from librdkafka-static-bundle-v2.4.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.4.0-RC2.tgz"
+const LibrdkafkaLinkInfo = "static darwin_arm64 from librdkafka-static-bundle-v2.4.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.4.0-RC2.tgz"
+const LibrdkafkaLinkInfo = "static glibc_linux_amd64 from librdkafka-static-bundle-v2.4.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.4.0-RC2.tgz"
+const LibrdkafkaLinkInfo = "static glibc_linux_arm64 from librdkafka-static-bundle-v2.4.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.4.0-RC2.tgz"
+const LibrdkafkaLinkInfo = "static musl_linux_amd64 from librdkafka-static-bundle-v2.4.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.4.0-RC2.tgz"
+const LibrdkafkaLinkInfo = "static musl_linux_arm64 from librdkafka-static-bundle-v2.4.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.4.0-RC2.tgz"
+const LibrdkafkaLinkInfo = "static windows from librdkafka-static-bundle-v2.4.0.tgz"
diff --git a/kafka/generated_errors.go b/kafka/generated_errors.go
@@ -1,7 +1,7 @@
 package kafka
 
 // Copyright 2016-2024 Confluent Inc.
-// AUTOMATICALLY GENERATED ON 2024-04-18 18:13:18.777581075 +0200 CEST m=+0.000160971 USING librdkafka 2.4.0-RC2
+// AUTOMATICALLY GENERATED ON 2024-05-07 12:59:28.782336233 +0200 CEST m=+0.000220978 USING librdkafka 2.4.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/kafka/librdkafka_vendor/librdkafka_windows.a b/kafka/librdkafka_vendor/librdkafka_windows.a
diff --git a/kafkatest/go.mod b/kafkatest/go.mod
@@ -8,7 +8,7 @@ replace github.com/confluentinc/confluent-kafka-go/v2 => ../
 
 require (
 	github.com/alecthomas/kingpin v2.2.6+incompatible
-	github.com/confluentinc/confluent-kafka-go/v2 v2.4.0-RC2
+	github.com/confluentinc/confluent-kafka-go/v2 v2.4.0
 )
 
 require (
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.4.0-RC2"
+    tag = "v2.4.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
@@ -215,19 +215,19 @@ <h3>
       </h3>
       <p>
        <span style="font-size:90%">
-        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/config.go">
+        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/config.go">
          config.go
         </a>
-        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/mock_schemaregistry_client.go">
+        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/mock_schemaregistry_client.go">
          mock_schemaregistry_client.go
         </a>
-        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/rest_service.go">
+        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/rest_service.go">
          rest_service.go
         </a>
-        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go">
+        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go">
          schemaregistry_client.go
         </a>
-        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/testhelpers.go">
+        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/testhelpers.go">
          testhelpers.go
         </a>
        </span>
@@ -258,7 +258,7 @@ <h2 id="pkg-constants">
 )</pre>
     <h2 id="Client">
      type
-     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=6747:7897#L194">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=6747:7897#L194">
       Client
      </a>
      <a class="permalink" href="#Client">
@@ -290,7 +290,7 @@ <h2 id="Client">
 }</pre>
      <h3 id="NewClient">
       func
-      <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=7944:7988#L213">
+      <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=7944:7988#L213">
        NewClient
       </a>
       <a class="permalink" href="#NewClient">
@@ -302,7 +302,7 @@ <h3 id="NewClient">
       NewClient returns a Client implementation
       <h2 id="Compatibility">
        type
-       <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=19493:19515#L595">
+       <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=19493:19515#L595">
         Compatibility
        </a>
        <a class="permalink" href="#Compatibility">
@@ -314,7 +314,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.4.0-RC2/schemaregistry/schemaregistry_client.go?s=20270:20322#L633">
+        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=20270:20322#L633">
          MarshalJSON
         </a>
         <a class="permalink" href="#Compatibility.MarshalJSON">
@@ -326,7 +326,7 @@ <h3 id="Compatibility.MarshalJSON">
         MarshalJSON implements json.Marshaler
         <h3 id="Compatibility.ParseString">
          func (*Compatibility)
-         <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=20743:20796#L652">
+         <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=20743:20796#L652">
           ParseString
          </a>
          <a class="permalink" href="#Compatibility.ParseString">
@@ -338,7 +338,7 @@ <h3 id="Compatibility.ParseString">
          ParseString returns a Compatibility for the given string
          <h3 id="Compatibility.String">
           func (Compatibility)
-          <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=20610:20648#L647">
+          <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=20610:20648#L647">
            String
           </a>
           <a class="permalink" href="#Compatibility.String">
@@ -348,7 +348,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.4.0-RC2/schemaregistry/schemaregistry_client.go?s=20406:20459#L638">
+          <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=20406:20459#L638">
            UnmarshalJSON
           </a>
           <a class="permalink" href="#Compatibility.UnmarshalJSON">
@@ -360,7 +360,7 @@ <h3 id="Compatibility.UnmarshalJSON">
           UnmarshalJSON implements json.Unmarshaler
           <h2 id="Config">
            type
-           <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/config.go?s=739:2685#L15">
+           <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/config.go?s=739:2685#L15">
             Config
            </a>
            <a class="permalink" href="#Config">
@@ -418,7 +418,7 @@ <h2 id="Config">
 </pre>
            <h3 id="NewConfig">
             func
-            <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/config.go?s=2757:2791#L63">
+            <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/config.go?s=2757:2791#L63">
              NewConfig
             </a>
             <a class="permalink" href="#NewConfig">
@@ -430,7 +430,7 @@ <h3 id="NewConfig">
             NewConfig returns a new configuration instance with sane defaults.
             <h3 id="NewConfigWithAuthentication">
              func
-             <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/config.go?s=3322:3408#L86">
+             <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/config.go?s=3322:3408#L86">
               NewConfigWithAuthentication
              </a>
              <a class="permalink" href="#NewConfigWithAuthentication">
@@ -444,7 +444,7 @@ <h3 id="NewConfigWithAuthentication">
 This method is deprecated.
              <h3 id="NewConfigWithBasicAuthentication">
               func
-              <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/config.go?s=3750:3841#L97">
+              <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/config.go?s=3750:3841#L97">
                NewConfigWithBasicAuthentication
               </a>
               <a class="permalink" href="#NewConfigWithBasicAuthentication">
@@ -457,7 +457,7 @@ <h3 id="NewConfigWithBasicAuthentication">
 For Confluent Cloud, use the API key for the username and the API secret for the password.
               <h3 id="NewConfigWithBearerAuthentication">
                func
-               <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/config.go?s=4220:4311#L109">
+               <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/config.go?s=4220:4311#L109">
                 NewConfigWithBearerAuthentication
                </a>
                <a class="permalink" href="#NewConfigWithBearerAuthentication">
@@ -471,7 +471,7 @@ <h3 id="NewConfigWithBearerAuthentication">
 identityPoolID(`bearer.auth.identity.pool.id`) is required
                <h2 id="Reference">
                 type
-                <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=3043:3164#L62">
+                <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=3043:3164#L62">
                  Reference
                 </a>
                 <a class="permalink" href="#Reference">
@@ -488,7 +488,7 @@ <h2 id="Reference">
 </pre>
                 <h2 id="RestError">
                  type
-                 <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/rest_service.go?s=2676:2770#L87">
+                 <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/rest_service.go?s=2676:2770#L87">
                   RestError
                  </a>
                  <a class="permalink" href="#RestError">
@@ -504,7 +504,7 @@ <h2 id="RestError">
 </pre>
                  <h3 id="RestError.Error">
                   func (*RestError)
-                  <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/rest_service.go?s=2819:2855#L93">
+                  <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/rest_service.go?s=2819:2855#L93">
                    Error
                   </a>
                   <a class="permalink" href="#RestError.Error">
@@ -516,7 +516,7 @@ <h3 id="RestError.Error">
                   Error implements the errors.Error interface
                   <h2 id="SchemaInfo">
                    type
-                   <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=3216:3400#L69">
+                   <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=3216:3400#L69">
                     SchemaInfo
                    </a>
                    <a class="permalink" href="#SchemaInfo">
@@ -533,7 +533,7 @@ <h2 id="SchemaInfo">
 </pre>
                    <h3 id="SchemaInfo.MarshalJSON">
                     func (*SchemaInfo)
-                    <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=3457:3508#L76">
+                    <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=3457:3508#L76">
                      MarshalJSON
                     </a>
                     <a class="permalink" href="#SchemaInfo.MarshalJSON">
@@ -545,7 +545,7 @@ <h3 id="SchemaInfo.MarshalJSON">
                     MarshalJSON implements the json.Marshaler interface
                     <h3 id="SchemaInfo.UnmarshalJSON">
                      func (*SchemaInfo)
-                     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=3821:3872#L89">
+                     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=3821:3872#L89">
                       UnmarshalJSON
                      </a>
                      <a class="permalink" href="#SchemaInfo.UnmarshalJSON">
@@ -557,7 +557,7 @@ <h3 id="SchemaInfo.UnmarshalJSON">
                      UnmarshalJSON implements the json.Unmarshaller interface
                      <h2 id="SchemaMetadata">
                       type
-                      <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=4254:4420#L107">
+                      <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=4254:4420#L107">
                        SchemaMetadata
                       </a>
                       <a class="permalink" href="#SchemaMetadata">
@@ -575,7 +575,7 @@ <h2 id="SchemaMetadata">
 </pre>
                       <h3 id="SchemaMetadata.MarshalJSON">
                        func (*SchemaMetadata)
-                       <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=4477:4532#L115">
+                       <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=4477:4532#L115">
                         MarshalJSON
                        </a>
                        <a class="permalink" href="#SchemaMetadata.MarshalJSON">
@@ -587,7 +587,7 @@ <h3 id="SchemaMetadata.MarshalJSON">
                        MarshalJSON implements the json.Marshaler interface
                        <h3 id="SchemaMetadata.UnmarshalJSON">
                         func (*SchemaMetadata)
-                        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=5033:5088#L134">
+                        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=5033:5088#L134">
                          UnmarshalJSON
                         </a>
                         <a class="permalink" href="#SchemaMetadata.UnmarshalJSON">
diff --git a/soaktest/go.mod b/soaktest/go.mod
@@ -8,7 +8,7 @@ replace github.com/confluentinc/confluent-kafka-go/v2 => ../
 
 require (
 	github.com/DataDog/datadog-go v4.8.3+incompatible
-	github.com/confluentinc/confluent-kafka-go/v2 v2.4.0-RC2
+	github.com/confluentinc/confluent-kafka-go/v2 v2.4.0
 	github.com/shirou/gopsutil v3.21.11+incompatible
 )
 

Original file line number	Diff line number	Diff line change
`@@ -2,7 +2,7 @@ module docker_example`
`2`	`2`
`3`	`3`	`require (`
`4`	`4`	`github.com/aws/aws-lambda-go v1.27.0`
`5`		`- github.com/confluentinc/confluent-kafka-go/v2 v2.4.0-RC2`
	`5`	`+ github.com/confluentinc/confluent-kafka-go/v2 v2.4.0`
`6`	`6`	`)`
`7`	`7`
`8`	`8`	`go 1.14`
Original file line number	Diff line number	Diff line change
`@@ -9,7 +9,7 @@ replace github.com/confluentinc/confluent-kafka-go/v2 => ../`
`9`	`9`	`require (`
`10`	`10`	`github.com/actgardner/gogen-avro/v10 v10.2.1`
`11`	`11`	`github.com/alecthomas/kingpin v2.2.6+incompatible`
`12`		`- github.com/confluentinc/confluent-kafka-go/v2 v2.4.0-RC2`
	`12`	`+ github.com/confluentinc/confluent-kafka-go/v2 v2.4.0`
`13`	`13`	`github.com/gdamore/tcell v1.4.0`
`14`	`14`	`google.golang.org/protobuf v1.33.0`
`15`	`15`	`)`