@@ -4,6 +4,28 @@ See also the [rdkafka-sys changelog](rdkafka-sys/changelog.md).
4
4
5
5
## Unreleased
6
6
7
+ * Add the ` StreamConsumer::split_partition_queue ` method to mirror
8
+ ` BaseConsumer::split_partition_queue ` ([ #411 ] ).
9
+
10
+ Thanks to [ @davidblewett ] , [ @duarten ] , and [ @nemosupremo ] for contributing to
11
+ the implementation.
12
+
13
+ * ** Breaking change.** Remove the ` StreamConsumerContext ` type and the
14
+ ` ConsumerContext::message_queue_nonempty_callback ` method. These were
15
+ essentially implementation details of ` StreamConsumer ` that had leaked into
16
+ the public API. The vast majority of users should be unaffected.
17
+
18
+ * ** Breaking change.** Remove the type parameters from the ` MessageStream ` type.
19
+
20
+ * ** Breaking change.** Add the received ` TopicPartitionList ` to the
21
+ ` Rebalance::Revoke ` variant, which is useful when using incremental
22
+ cooperative rebalancing ([ #398 ] ).
23
+
24
+ * Avoid crashing if librdkafka invokes the commit callback with a null
25
+ topic partition list ([ #406 ] ).
26
+
27
+ Thanks, [ @thijsc ] .
28
+
7
29
* Add the new statistics fields in librdkafka v1.7.0 to the various statistics
8
30
types. The new fields are:
9
31
@@ -46,21 +68,28 @@ See also the [rdkafka-sys changelog](rdkafka-sys/changelog.md).
46
68
statistics from librdkafka. The default implementation calls
47
69
` ClientContext::stats ` with the decoded statistics.
48
70
49
- * ** Breaking change. ** Add the received ` TopicPartitionList ` to the
50
- ` Rebalance::Revoke ` variant, which is useful when using incremental
51
- cooperative rebalancing ([ #398 ] ).
71
+ * Add the ` Default ` trait to the statistics types: ` Statistics ` , ` Broker ` ,
72
+ ` Window ` , ` TopicPartition ` , ` Topic ` , ` Partition ` , ` ConsumerGroup ` , and
73
+ ` ExactlyOnceSemantics ` ([ #410 ] ).
52
74
53
- * ** Breaking change.** Remove the ` StreamConsumerContext ` type and the
54
- ` ConsumerContext::message_queue_nonempty_callback ` method. These were
55
- essentially implementation details of ` StreamConsumer ` that had leaked into
56
- the public API. The vast majority of users should be unaffected.
75
+ Thanks, [ @scanterog ] .
57
76
58
- * ** Breaking change.** The ` MessageStream ` type is no longer generic.
77
+ * Add the ` Debug ` trait to ` DefaultClientContext ` and ` DefaultConsumerContext `
78
+ ([ #401 ] ).
59
79
60
- * Add the ` StreamConsumer::split_partition_queue ` method to mirror
61
- ` BaseConsumer::split_partition_queue ` .
80
+ Thanks, [ @DXist ] .
62
81
63
82
[ #398 ] : https://github.com/fede1024/rust-rdkafka/issues/398
83
+ [ #401 ] : https://github.com/fede1024/rust-rdkafka/issues/401
84
+ [ #406 ] : https://github.com/fede1024/rust-rdkafka/issues/406
85
+ [ #410 ] : https://github.com/fede1024/rust-rdkafka/issues/410
86
+ [ #411 ] : https://github.com/fede1024/rust-rdkafka/issues/411
87
+ [ @davidblewett ] : https://github.com/davidblewett
88
+ [ @duarten ] : https://github.com/duarten
89
+ [ @DXist ] : https://github.com/DXist
90
+ [ @nemosupremo ] : https://github.com/nemosupremo
91
+ [ @scanterog ] : https://github.com/scanterog
92
+ [ @thijsc ] : https://github.com/thijsc
64
93
65
94
<a name =" 0.27.0 " ></a >
66
95
## 0.27.0 (2021-10-17)
0 commit comments