From 4018f5e8b3314b142810ad882d43ea610bdcc81e Mon Sep 17 00:00:00 2001 From: Boyang Chen Date: Thu, 26 Mar 2020 09:40:49 -0700 Subject: [PATCH] KAFKA-9760: Add KIP-447 protocol change to upgrade notes (#8350) Reviewers: Matthias J. Sax , Guozhang Wang --- docs/upgrade.html | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/docs/upgrade.html b/docs/upgrade.html index bb30735ddb4..23910254943 100644 --- a/docs/upgrade.html +++ b/docs/upgrade.html @@ -30,6 +30,15 @@ zookeeper.session.timeout.ms has been increased from 6s to 18s and replica.lag.time.max.ms from 10s to 30s.
  • New DSL operator cogroup() has been added for aggregating multiple streams together at once.
    • +
  • Added a new KStream.toTable() API to translate an input event stream into a KTable.
    • +
  • Added a new Serde type Void to represent null keys or null values from input topic.
    • +
  • Deprecated UsePreviousTimeOnInvalidTimestamp and replaced it with UsePartitionTimeOnInvalidTimeStamp.
    • +
  • 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 + examples folder. Check out + KIP-447 + for the full details.
  • Scala 2.11 is no longer supported. See KIP-531 for details.