You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2020/03/30 20:14:18 UTC
[kafka] 01/02: KAFKA-9760: Add KIP-447 protocol change to upgrade
notes (#8350)
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch 2.5
in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 622a3ac1e87d04b4728845bfc29c3772868cb4f9
Author: Boyang Chen <bo...@confluent.io>
AuthorDate: Thu Mar 26 09:40:49 2020 -0700
KAFKA-9760: Add KIP-447 protocol change to upgrade notes (#8350)
Reviewers: Matthias J. Sax <ma...@confluent.io>, Guozhang Wang <gu...@confluent.io>
---
docs/upgrade.html | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git a/docs/upgrade.html b/docs/upgrade.html
index bb30735..2391025 100644
--- a/docs/upgrade.html
+++ b/docs/upgrade.html
@@ -30,6 +30,15 @@
<code>zookeeper.session.timeout.ms</code> has been increased from 6s to 18s and
<code>replica.lag.time.max.ms</code> from 10s to 30s.</li>
<li>New DSL operator <code>cogroup()</code> has been added for aggregating multiple streams together at once.</li>
+ <li>Added a new <code>KStream.toTable()</code> API to translate an input event stream into a KTable.</li>
+ <li>Added a new Serde type <code>Void</code> to represent null keys or null values from input topic.</li>
+ <li>Deprecated <code>UsePreviousTimeOnInvalidTimestamp</code> and replaced it with <code>UsePartitionTimeOnInvalidTimeStamp</code>.</li>
+ <li>Improved exactly-once semantics by adding a pending offset fencing mechanism and stronger transactional commit
+ consistency check, which greatly simplifies the implementation of a scalable exactly-once application.
+ We also added a new exactly-once semantics code example under
+ <a href="https://github.com/apache/kafka/tree/2.5/examples">examples</a> folder. Check out
+ <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-447%3A+Producer+scalability+for+exactly+once+semantics">KIP-447</a>
+ for the full details.</li>
<li>Scala 2.11 is no longer supported. See
<a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-531%3A+Drop+support+for+Scala+2.11+in+Kafka+2.5">KIP-531</a>
for details.</li>