+133
-113
lines changedFilter options
+133
-113
lines changed Original file line number Diff line number Diff line change
@@ -2,6 +2,30 @@
2
2
3
3
librdkafka v2.10.0 is a feature release:
4
4
5
+
## [KIP-848](https://cwiki.apache.org/confluence/display/KAFKA/KIP-848%3A+The+Next+Generation+of+the+Consumer+Rebalance+Protocol) – Now in **Preview**
6
+
7
+
- [KIP-848](https://cwiki.apache.org/confluence/display/KAFKA/KIP-848%3A+The+Next+Generation+of+the+Consumer+Rebalance+Protocol) has transitioned from *Early Access* to *Preview*.
8
+
- Added support for **regex-based subscriptions**.
9
+
- Implemented client-side member ID generation as per [KIP-1082](https://cwiki.apache.org/confluence/display/KAFKA/KIP-1082%3A+Require+Client-Generated+IDs+over+the+ConsumerGroupHeartbeat+RPC).
10
+
- `rd_kafka_DescribeConsumerGroups()` now supports KIP-848-style `consumer` groups. Two new fields have been added:
11
+
- **Group type** – Indicates whether the group is `classic` or `consumer`.
12
+
- **Target assignment** – Applicable only to `consumer` protocol groups (defaults to `NULL`).
13
+
- Group configuration is now supported in `AlterConfigs`, `IncrementalAlterConfigs`, and `DescribeConfigs`. ([#4939](https://github.com/confluentinc/librdkafka/pull/4939))
14
+
- Added **Topic Authorization Error** support in the `ConsumerGroupHeartbeat` response.
15
+
- Removed usage of the `partition.assignment.strategy` property for the `consumer` group protocol. An error will be raised if this is set with `group.protocol=consumer`.
16
+
- Deprecated and disallowed the following properties for the `consumer` group protocol:
17
+
- `session.timeout.ms`
18
+
- `heartbeat.interval.ms`
19
+
- `group.protocol.type`
20
+
Attempting to set any of these will result in an error.
21
+
- Enhanced handling for `subscribe()` and `unsubscribe()` edge cases.
22
+
23
+
> [!Note]
24
+
> The [KIP-848](https://cwiki.apache.org/confluence/display/KAFKA/KIP-848%3A+The+Next+Generation+of+the+Consumer+Rebalance+Protocol) consumer is currently in **Preview** and should not be used in production environments. Implementation is feature complete but contract could have minor changes before General Availability.
25
+
26
+
27
+
## Enhancements and Fixes
28
+
5
29
* Identify brokers only by broker id (#4557, @mfleming)
6
30
* Remove unavailable brokers and their thread (#4557, @mfleming)
7
31
* Commits during a cooperative incremental rebalance aren't causing
@@ -39,8 +63,6 @@ librdkafka v2.10.0 is a feature release:
39
63
leader change and offset validation (#4970).
40
64
* Fix the Nagle algorithm (TCP_NODELAY) on broker sockets to not be enabled
41
65
by default (#4986).
42
-
* [KIP-848] `rd_kafka_DescribeConsumerGroups()` now supports KIP-848 introduced `consumer` groups. Two new fields for consumer group type and target assignment have also been added. Type defines whether this group is a `classic` or `consumer` group. Target assignment is only valid for the `consumer` protocol and its defaults to NULL. (#4922).
43
-
* [KIP-848] Group Config is now supported in AlterConfigs, IncrementalAlterConfigs and DescribeConfigs. (#4939).
44
66
45
67
46
68
## Fixes
You can’t perform that action at this time.
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4