librdkafka v2.1.1 (#990)

confluentinc · May 3, 2023 · 9a07b92 · 9a07b92
2 parents 4abbbd4 + 8c4025a
commit 9a07b92
Show file tree

Hide file tree

Showing 22 changed files with 296 additions and 296 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.1.1-RC1
+      value: v2.1.1
   prologue:
     commands:
       - checkout

diff --git a/examples/go.mod b/examples/go.mod
@@ -8,7 +8,7 @@ require (
 	github.com/actgardner/gogen-avro/v10 v10.2.1
 	github.com/alecthomas/kingpin v2.2.6+incompatible
 	github.com/alecthomas/units v0.0.0-20211218093645-b94a6e3cc137 // indirect
-	github.com/confluentinc/confluent-kafka-go/v2 v2.1.1-RC1
+	github.com/confluentinc/confluent-kafka-go/v2 v2.1.1
 	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.1.1-RC1.tgz"
+const LibrdkafkaLinkInfo = "static darwin_amd64 from librdkafka-static-bundle-v2.1.1.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.1.1-RC1.tgz"
+const LibrdkafkaLinkInfo = "static darwin_arm64 from librdkafka-static-bundle-v2.1.1.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.1.1-RC1.tgz"
+const LibrdkafkaLinkInfo = "static glibc_linux_amd64 from librdkafka-static-bundle-v2.1.1.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.1.1-RC1.tgz"
+const LibrdkafkaLinkInfo = "static glibc_linux_arm64 from librdkafka-static-bundle-v2.1.1.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.1.1-RC1.tgz"
+const LibrdkafkaLinkInfo = "static musl_linux_amd64 from librdkafka-static-bundle-v2.1.1.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.1.1-RC1.tgz"
+const LibrdkafkaLinkInfo = "static musl_linux_arm64 from librdkafka-static-bundle-v2.1.1.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.1.1-RC1.tgz"
+const LibrdkafkaLinkInfo = "static windows from librdkafka-static-bundle-v2.1.1.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-04-24 19:07:34.198876259 +0200 CEST m=+0.000174906 USING librdkafka 2.1.1-RC1
+// AUTOMATICALLY GENERATED ON 2023-05-02 21:19:57.562336161 +0200 CEST m=+0.004897798 USING librdkafka 2.1.1
 
 /*
 #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
@@ -7,5 +7,5 @@ replace github.com/confluentinc/confluent-kafka-go/v2 => ../
 require (
 	github.com/alecthomas/kingpin v2.2.6+incompatible
 	github.com/alecthomas/units v0.0.0-20211218093645-b94a6e3cc137 // indirect
-	github.com/confluentinc/confluent-kafka-go/v2 v2.1.1-RC1
+	github.com/confluentinc/confluent-kafka-go/v2 v2.1.1
 )
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.1.1-RC1"
+    tag = "v2.1.1"
     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.1.1-RC1/schemaregistry/config.go">
+        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/schemaregistry/config.go">
          config.go
         </a>
-        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1-RC1/schemaregistry/mock_schemaregistry_client.go">
+        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/schemaregistry/mock_schemaregistry_client.go">
          mock_schemaregistry_client.go
         </a>
-        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1-RC1/schemaregistry/rest_service.go">
+        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/schemaregistry/rest_service.go">
          rest_service.go
         </a>
-        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1-RC1/schemaregistry/schemaregistry_client.go">
+        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/schemaregistry/schemaregistry_client.go">
          schemaregistry_client.go
         </a>
-        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1-RC1/schemaregistry/testhelpers.go">
+        <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/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.1.1-RC1/schemaregistry/schemaregistry_client.go?s=6422:7572#L182">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/schemaregistry/schemaregistry_client.go?s=6422:7572#L182">
       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.1.1-RC1/schemaregistry/schemaregistry_client.go?s=7619:7663#L201">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/schemaregistry/schemaregistry_client.go?s=7619:7663#L201">
       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.1.1-RC1/schemaregistry/schemaregistry_client.go?s=16563:16585#L511">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/schemaregistry/schemaregistry_client.go?s=16563:16585#L511">
       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.1.1-RC1/schemaregistry/schemaregistry_client.go?s=17340:17392#L549">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/schemaregistry/schemaregistry_client.go?s=17340:17392#L549">
       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.1.1-RC1/schemaregistry/schemaregistry_client.go?s=17813:17866#L568">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/schemaregistry/schemaregistry_client.go?s=17813:17866#L568">
       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.1.1-RC1/schemaregistry/schemaregistry_client.go?s=17680:17718#L563">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/schemaregistry/schemaregistry_client.go?s=17680:17718#L563">
       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.1.1-RC1/schemaregistry/schemaregistry_client.go?s=17476:17529#L554">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/schemaregistry/schemaregistry_client.go?s=17476:17529#L554">
       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.1.1-RC1/schemaregistry/config.go?s=722:2038#L12">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/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.1.1-RC1/schemaregistry/config.go?s=2110:2144#L46">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/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.1.1-RC1/schemaregistry/config.go?s=2710:2796#L71">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/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.1.1-RC1/schemaregistry/schemaregistry_client.go?s=3024:3145#L60">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/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.1.1-RC1/schemaregistry/rest_service.go?s=2572:2666#L84">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/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.1.1-RC1/schemaregistry/rest_service.go?s=2715:2751#L90">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/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.1.1-RC1/schemaregistry/schemaregistry_client.go?s=3197:3381#L67">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/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.1.1-RC1/schemaregistry/schemaregistry_client.go?s=3438:3489#L74">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/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.1.1-RC1/schemaregistry/schemaregistry_client.go?s=3802:3853#L87">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/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.1.1-RC1/schemaregistry/schemaregistry_client.go?s=4235:4401#L105">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/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.1.1-RC1/schemaregistry/schemaregistry_client.go?s=4458:4513#L113">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/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.1.1-RC1/schemaregistry/schemaregistry_client.go?s=5014:5069#L132">
+     <a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.1.1/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.1.1-RC1
+	github.com/confluentinc/confluent-kafka-go/v2 v2.1.1
 	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