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:17 UTC
[kafka] branch 2.5 updated (bf7c23d -> ae29cb8)
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch 2.5
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from bf7c23d MINOR: Fix error message in exception when records have schemas in Connect's Flatten transformation (#3982)
new 622a3ac KAFKA-9760: Add KIP-447 protocol change to upgrade notes (#8350)
new ae29cb8 MINOR: Update docs for KIP-530 and KIP-562 (#8388)
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/streams/upgrade-guide.html | 9 +++++++--
docs/upgrade.html | 10 ++++++++++
2 files changed, 17 insertions(+), 2 deletions(-)
[kafka] 01/02: KAFKA-9760: Add KIP-447 protocol change to upgrade
notes (#8350)
Posted by mj...@apache.org.
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>
[kafka] 02/02: MINOR: Update docs for KIP-530 and KIP-562 (#8388)
Posted by mj...@apache.org.
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 ae29cb85134848aedfaee589c57ad6eedb7a5f0e
Author: Boyang Chen <bo...@confluent.io>
AuthorDate: Mon Mar 30 13:06:54 2020 -0700
MINOR: Update docs for KIP-530 and KIP-562 (#8388)
Reviewer: Matthias J. Sax <ma...@confluent.io>
---
docs/streams/upgrade-guide.html | 9 +++++++--
docs/upgrade.html | 1 +
2 files changed, 8 insertions(+), 2 deletions(-)
diff --git a/docs/streams/upgrade-guide.html b/docs/streams/upgrade-guide.html
index 78f1ccc..c6b9826 100644
--- a/docs/streams/upgrade-guide.html
+++ b/docs/streams/upgrade-guide.html
@@ -88,8 +88,13 @@
null keys or null values from input topic.
</p>
<p>
- As of 2.5.0 Kafka we deprecated <code>UsePreviousTimeOnInvalidTimestamp</code> and replaced it with <code>UsePartitionTimeOnInvalidTimeStamp</code> as per
- <a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=130028807">KIP-530</a>
+ Deprecated <code>UsePreviousTimeOnInvalidTimestamp</code> and replaced it with <code>UsePartitionTimeOnInvalidTimeStamp</code> as per
+ <a href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=130028807">KIP-530</a>.
+ </p>
+ <p>
+ Deprecated <code>KafkaStreams.store(String, QueryableStoreType)</code> and replaced it with <code>KafkaStreams.store(StoreQueryParameters)</code> to allow querying
+ for specific partition and specific task type as per
+ <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-562%3A+Allow+fetching+a+key+from+a+single+partition+rather+than+iterating+over+all+the+stores+on+an+instance">KIP-562</a>.
</p>
<h3><a id="streams_api_changes_240" href="#streams_api_changes_240">Streams API changes in 2.4.0</a></h3>
diff --git a/docs/upgrade.html b/docs/upgrade.html
index 2391025..6d05b6d 100644
--- a/docs/upgrade.html
+++ b/docs/upgrade.html
@@ -39,6 +39,7 @@
<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>Deprecated <code>KafkaStreams.store(String, QueryableStoreType)</code> and replaced it with <code>KafkaStreams.store(StoreQueryParameters)</code>.</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>