Skip to content

Commit 1bb141d

Browse files
milindlmilindl
authored
librdkafka v2.4.0 (#1188)
2 parents 105797d + 663adb0 commit 1bb141d

24 files changed

+345
-345
lines changed

‎.semaphore/semaphore.yml

+1-1
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ agent:
66
global_job_config:
77
env_vars:
88
- name: LIBRDKAFKA_VERSION
9-
value: v2.4.0-RC2
9+
value: v2.4.0
1010
prologue:
1111
commands:
1212
- checkout

‎CHANGELOG.md

+2-2
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@
44

55
This is a feature release.
66

7-
* [KIP-848 EA](https://cwiki.apache.org/confluence/display/KAFKA/KIP-848%3A+The+Next+Generation+of+the+Consumer+Rebalance+Protocol):
8-
Integration tests running with the new consumer group protocol. The feature is an Early Access: not production ready, still not supported (#1185).
7+
* [KIP-848](https://cwiki.apache.org/confluence/display/KAFKA/KIP-848%3A+The+Next+Generation+of+the+Consumer+Rebalance+Protocol):
8+
Integration tests running with the new consumer group protocol. The feature is an **Early Access**: not production ready (#1185).
99

1010
## Fixes
1111

‎examples/docker_aws_lambda_example/go.mod

+1-1
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ module docker_example
22

33
require (
44
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
66
)
77

88
go 1.14

‎examples/go.mod

+1-1
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ replace github.com/confluentinc/confluent-kafka-go/v2 => ../
99
require (
1010
github.com/actgardner/gogen-avro/v10 v10.2.1
1111
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
1313
github.com/gdamore/tcell v1.4.0
1414
google.golang.org/protobuf v1.33.0
1515
)

‎kafka/api.html

+303-303
Large diffs are not rendered by default.

‎kafka/build_darwin_amd64.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -10,4 +10,4 @@ package kafka
1010
import "C"
1111

1212
// LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client
13-
const LibrdkafkaLinkInfo = "static darwin_amd64 from librdkafka-static-bundle-v2.4.0-RC2.tgz"
13+
const LibrdkafkaLinkInfo = "static darwin_amd64 from librdkafka-static-bundle-v2.4.0.tgz"

‎kafka/build_darwin_arm64.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -10,4 +10,4 @@ package kafka
1010
import "C"
1111

1212
// LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client
13-
const LibrdkafkaLinkInfo = "static darwin_arm64 from librdkafka-static-bundle-v2.4.0-RC2.tgz"
13+
const LibrdkafkaLinkInfo = "static darwin_arm64 from librdkafka-static-bundle-v2.4.0.tgz"

‎kafka/build_glibc_linux_amd64.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -10,4 +10,4 @@ package kafka
1010
import "C"
1111

1212
// LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client
13-
const LibrdkafkaLinkInfo = "static glibc_linux_amd64 from librdkafka-static-bundle-v2.4.0-RC2.tgz"
13+
const LibrdkafkaLinkInfo = "static glibc_linux_amd64 from librdkafka-static-bundle-v2.4.0.tgz"

‎kafka/build_glibc_linux_arm64.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -10,4 +10,4 @@ package kafka
1010
import "C"
1111

1212
// LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client
13-
const LibrdkafkaLinkInfo = "static glibc_linux_arm64 from librdkafka-static-bundle-v2.4.0-RC2.tgz"
13+
const LibrdkafkaLinkInfo = "static glibc_linux_arm64 from librdkafka-static-bundle-v2.4.0.tgz"

‎kafka/build_musl_linux_amd64.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -10,4 +10,4 @@ package kafka
1010
import "C"
1111

1212
// LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client
13-
const LibrdkafkaLinkInfo = "static musl_linux_amd64 from librdkafka-static-bundle-v2.4.0-RC2.tgz"
13+
const LibrdkafkaLinkInfo = "static musl_linux_amd64 from librdkafka-static-bundle-v2.4.0.tgz"

‎kafka/build_musl_linux_arm64.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -10,4 +10,4 @@ package kafka
1010
import "C"
1111

1212
// LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client
13-
const LibrdkafkaLinkInfo = "static musl_linux_arm64 from librdkafka-static-bundle-v2.4.0-RC2.tgz"
13+
const LibrdkafkaLinkInfo = "static musl_linux_arm64 from librdkafka-static-bundle-v2.4.0.tgz"

‎kafka/build_windows.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -10,4 +10,4 @@ package kafka
1010
import "C"
1111

1212
// LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client
13-
const LibrdkafkaLinkInfo = "static windows from librdkafka-static-bundle-v2.4.0-RC2.tgz"
13+
const LibrdkafkaLinkInfo = "static windows from librdkafka-static-bundle-v2.4.0.tgz"

‎kafka/generated_errors.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package kafka
22

33
// Copyright 2016-2024 Confluent Inc.
4-
// AUTOMATICALLY GENERATED ON 2024-04-18 18:13:18.777581075 +0200 CEST m=+0.000160971 USING librdkafka 2.4.0-RC2
4+
// AUTOMATICALLY GENERATED ON 2024-05-07 12:59:28.782336233 +0200 CEST m=+0.000220978 USING librdkafka 2.4.0
55

66
/*
77
#include "select_rdkafka.h"

‎kafka/librdkafka_vendor/librdkafka_darwin_amd64.a

192 Bytes
Binary file not shown.

‎kafka/librdkafka_vendor/librdkafka_darwin_arm64.a

144 Bytes
Binary file not shown.

‎kafka/librdkafka_vendor/librdkafka_glibc_linux_amd64.a

384 Bytes
Binary file not shown.

‎kafka/librdkafka_vendor/librdkafka_glibc_linux_arm64.a

280 Bytes
Binary file not shown.

‎kafka/librdkafka_vendor/librdkafka_musl_linux_amd64.a

272 Bytes
Binary file not shown.

‎kafka/librdkafka_vendor/librdkafka_musl_linux_arm64.a

296 Bytes
Binary file not shown.

‎kafka/librdkafka_vendor/librdkafka_windows.a

174 Bytes
Binary file not shown.

‎kafkatest/go.mod

+1-1
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ replace github.com/confluentinc/confluent-kafka-go/v2 => ../
88

99
require (
1010
github.com/alecthomas/kingpin v2.2.6+incompatible
11-
github.com/confluentinc/confluent-kafka-go/v2 v2.4.0-RC2
11+
github.com/confluentinc/confluent-kafka-go/v2 v2.4.0
1212
)
1313

1414
require (

‎mk/doc-gen.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ def convert_path(url, base_url, after):
2424
sys.exit(1)
2525
package = sys.argv[1]
2626

27-
tag = "v2.4.0-RC2"
27+
tag = "v2.4.0"
2828
major = tag.split(".")[0] # e.g. v2
2929
base_css = "https://go.dev/css"
3030
base_js = "https://go.dev/js"

‎schemaregistry/api.html

+26-26
Original file line numberDiff line numberDiff line change
@@ -215,19 +215,19 @@ <h3>
215215
</h3>
216216
<p>
217217
<span style="font-size:90%">
218-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/config.go">
218+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/config.go">
219219
config.go
220220
</a>
221-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/mock_schemaregistry_client.go">
221+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/mock_schemaregistry_client.go">
222222
mock_schemaregistry_client.go
223223
</a>
224-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/rest_service.go">
224+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/rest_service.go">
225225
rest_service.go
226226
</a>
227-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go">
227+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go">
228228
schemaregistry_client.go
229229
</a>
230-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/testhelpers.go">
230+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/testhelpers.go">
231231
testhelpers.go
232232
</a>
233233
</span>
@@ -258,7 +258,7 @@ <h2 id="pkg-constants">
258258
)</pre>
259259
<h2 id="Client">
260260
type
261-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=6747:7897#L194">
261+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=6747:7897#L194">
262262
Client
263263
</a>
264264
<a class="permalink" href="#Client">
@@ -290,7 +290,7 @@ <h2 id="Client">
290290
}</pre>
291291
<h3 id="NewClient">
292292
func
293-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=7944:7988#L213">
293+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=7944:7988#L213">
294294
NewClient
295295
</a>
296296
<a class="permalink" href="#NewClient">
@@ -302,7 +302,7 @@ <h3 id="NewClient">
302302
NewClient returns a Client implementation
303303
<h2 id="Compatibility">
304304
type
305-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=19493:19515#L595">
305+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=19493:19515#L595">
306306
Compatibility
307307
</a>
308308
<a class="permalink" href="#Compatibility">
@@ -314,7 +314,7 @@ <h2 id="Compatibility">
314314
<pre>type Compatibility <a href="https://pkg.go.dev/builtin/#int">int</a></pre>
315315
<h3 id="Compatibility.MarshalJSON">
316316
func (Compatibility)
317-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=20270:20322#L633">
317+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=20270:20322#L633">
318318
MarshalJSON
319319
</a>
320320
<a class="permalink" href="#Compatibility.MarshalJSON">
@@ -326,7 +326,7 @@ <h3 id="Compatibility.MarshalJSON">
326326
MarshalJSON implements json.Marshaler
327327
<h3 id="Compatibility.ParseString">
328328
func (*Compatibility)
329-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=20743:20796#L652">
329+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=20743:20796#L652">
330330
ParseString
331331
</a>
332332
<a class="permalink" href="#Compatibility.ParseString">
@@ -338,7 +338,7 @@ <h3 id="Compatibility.ParseString">
338338
ParseString returns a Compatibility for the given string
339339
<h3 id="Compatibility.String">
340340
func (Compatibility)
341-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=20610:20648#L647">
341+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=20610:20648#L647">
342342
String
343343
</a>
344344
<a class="permalink" href="#Compatibility.String">
@@ -348,7 +348,7 @@ <h3 id="Compatibility.String">
348348
<pre>func (c <a href="#Compatibility">Compatibility</a>) String() <a href="https://pkg.go.dev/builtin/#string">string</a></pre>
349349
<h3 id="Compatibility.UnmarshalJSON">
350350
func (*Compatibility)
351-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=20406:20459#L638">
351+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=20406:20459#L638">
352352
UnmarshalJSON
353353
</a>
354354
<a class="permalink" href="#Compatibility.UnmarshalJSON">
@@ -360,7 +360,7 @@ <h3 id="Compatibility.UnmarshalJSON">
360360
UnmarshalJSON implements json.Unmarshaler
361361
<h2 id="Config">
362362
type
363-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/config.go?s=739:2685#L15">
363+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/config.go?s=739:2685#L15">
364364
Config
365365
</a>
366366
<a class="permalink" href="#Config">
@@ -418,7 +418,7 @@ <h2 id="Config">
418418
</pre>
419419
<h3 id="NewConfig">
420420
func
421-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/config.go?s=2757:2791#L63">
421+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/config.go?s=2757:2791#L63">
422422
NewConfig
423423
</a>
424424
<a class="permalink" href="#NewConfig">
@@ -430,7 +430,7 @@ <h3 id="NewConfig">
430430
NewConfig returns a new configuration instance with sane defaults.
431431
<h3 id="NewConfigWithAuthentication">
432432
func
433-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/config.go?s=3322:3408#L86">
433+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/config.go?s=3322:3408#L86">
434434
NewConfigWithAuthentication
435435
</a>
436436
<a class="permalink" href="#NewConfigWithAuthentication">
@@ -444,7 +444,7 @@ <h3 id="NewConfigWithAuthentication">
444444
This method is deprecated.
445445
<h3 id="NewConfigWithBasicAuthentication">
446446
func
447-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/config.go?s=3750:3841#L97">
447+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/config.go?s=3750:3841#L97">
448448
NewConfigWithBasicAuthentication
449449
</a>
450450
<a class="permalink" href="#NewConfigWithBasicAuthentication">
@@ -457,7 +457,7 @@ <h3 id="NewConfigWithBasicAuthentication">
457457
For Confluent Cloud, use the API key for the username and the API secret for the password.
458458
<h3 id="NewConfigWithBearerAuthentication">
459459
func
460-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/config.go?s=4220:4311#L109">
460+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/config.go?s=4220:4311#L109">
461461
NewConfigWithBearerAuthentication
462462
</a>
463463
<a class="permalink" href="#NewConfigWithBearerAuthentication">
@@ -471,7 +471,7 @@ <h3 id="NewConfigWithBearerAuthentication">
471471
identityPoolID(`bearer.auth.identity.pool.id`) is required
472472
<h2 id="Reference">
473473
type
474-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=3043:3164#L62">
474+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=3043:3164#L62">
475475
Reference
476476
</a>
477477
<a class="permalink" href="#Reference">
@@ -488,7 +488,7 @@ <h2 id="Reference">
488488
</pre>
489489
<h2 id="RestError">
490490
type
491-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/rest_service.go?s=2676:2770#L87">
491+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/rest_service.go?s=2676:2770#L87">
492492
RestError
493493
</a>
494494
<a class="permalink" href="#RestError">
@@ -504,7 +504,7 @@ <h2 id="RestError">
504504
</pre>
505505
<h3 id="RestError.Error">
506506
func (*RestError)
507-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/rest_service.go?s=2819:2855#L93">
507+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/rest_service.go?s=2819:2855#L93">
508508
Error
509509
</a>
510510
<a class="permalink" href="#RestError.Error">
@@ -516,7 +516,7 @@ <h3 id="RestError.Error">
516516
Error implements the errors.Error interface
517517
<h2 id="SchemaInfo">
518518
type
519-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=3216:3400#L69">
519+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=3216:3400#L69">
520520
SchemaInfo
521521
</a>
522522
<a class="permalink" href="#SchemaInfo">
@@ -533,7 +533,7 @@ <h2 id="SchemaInfo">
533533
</pre>
534534
<h3 id="SchemaInfo.MarshalJSON">
535535
func (*SchemaInfo)
536-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=3457:3508#L76">
536+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=3457:3508#L76">
537537
MarshalJSON
538538
</a>
539539
<a class="permalink" href="#SchemaInfo.MarshalJSON">
@@ -545,7 +545,7 @@ <h3 id="SchemaInfo.MarshalJSON">
545545
MarshalJSON implements the json.Marshaler interface
546546
<h3 id="SchemaInfo.UnmarshalJSON">
547547
func (*SchemaInfo)
548-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=3821:3872#L89">
548+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=3821:3872#L89">
549549
UnmarshalJSON
550550
</a>
551551
<a class="permalink" href="#SchemaInfo.UnmarshalJSON">
@@ -557,7 +557,7 @@ <h3 id="SchemaInfo.UnmarshalJSON">
557557
UnmarshalJSON implements the json.Unmarshaller interface
558558
<h2 id="SchemaMetadata">
559559
type
560-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=4254:4420#L107">
560+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=4254:4420#L107">
561561
SchemaMetadata
562562
</a>
563563
<a class="permalink" href="#SchemaMetadata">
@@ -575,7 +575,7 @@ <h2 id="SchemaMetadata">
575575
</pre>
576576
<h3 id="SchemaMetadata.MarshalJSON">
577577
func (*SchemaMetadata)
578-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=4477:4532#L115">
578+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=4477:4532#L115">
579579
MarshalJSON
580580
</a>
581581
<a class="permalink" href="#SchemaMetadata.MarshalJSON">
@@ -587,7 +587,7 @@ <h3 id="SchemaMetadata.MarshalJSON">
587587
MarshalJSON implements the json.Marshaler interface
588588
<h3 id="SchemaMetadata.UnmarshalJSON">
589589
func (*SchemaMetadata)
590-
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0-RC2/schemaregistry/schemaregistry_client.go?s=5033:5088#L134">
590+
<a href="https://github.com/confluentinc/confluent-kafka-go/blob/v2.4.0/schemaregistry/schemaregistry_client.go?s=5033:5088#L134">
591591
UnmarshalJSON
592592
</a>
593593
<a class="permalink" href="#SchemaMetadata.UnmarshalJSON">

‎soaktest/go.mod

+1-1
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ replace github.com/confluentinc/confluent-kafka-go/v2 => ../
88

99
require (
1010
github.com/DataDog/datadog-go v4.8.3+incompatible
11-
github.com/confluentinc/confluent-kafka-go/v2 v2.4.0-RC2
11+
github.com/confluentinc/confluent-kafka-go/v2 v2.4.0
1212
github.com/shirou/gopsutil v3.21.11+incompatible
1313
)
1414

0 commit comments

Comments
 (0)