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/06/10 21:13:40 UTC
[kafka-site] branch asf-site updated: Minor: Updating upgrade docs
for KIP-535 and KIP-562 (#267)
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/kafka-site.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 741d4fb Minor: Updating upgrade docs for KIP-535 and KIP-562 (#267)
741d4fb is described below
commit 741d4fb77593b29002b73405517b5a29b9d06b9c
Author: Navinder Pal Singh Brar <na...@yahoo.com>
AuthorDate: Thu Jun 11 02:43:33 2020 +0530
Minor: Updating upgrade docs for KIP-535 and KIP-562 (#267)
Reviewer: Matthias J. Sax <ma...@confluent.io>
---
25/streams/upgrade-guide.html | 5 +++--
25/upgrade.html | 5 ++++-
2 files changed, 7 insertions(+), 3 deletions(-)
diff --git a/25/streams/upgrade-guide.html b/25/streams/upgrade-guide.html
index 17fd5e9..88d4b99 100644
--- a/25/streams/upgrade-guide.html
+++ b/25/streams/upgrade-guide.html
@@ -93,8 +93,9 @@
</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>.
+ for a store with variety of parameters, including querying a specific task and stale stores, 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> and
+ <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-535%3A+Allow+state+stores+to+serve+stale+reads+during+rebalance">KIP-535</a> respectively.
</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/25/upgrade.html b/25/upgrade.html
index 701d097..622fc42 100644
--- a/25/upgrade.html
+++ b/25/upgrade.html
@@ -81,7 +81,10 @@
<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>Added a new public api <code>KafkaStreams.queryMetadataForKey(String, K, Serializer) to get detailed information on the key being queried.
+ It provides information about the partition number where the key resides in addition to hosts containing the active and standby partitions for the key.</code></li>
+ <li>Provided support to query stale stores (for high availability) and the stores belonging to a specific partition by deprecating <code>KafkaStreams.store(String, QueryableStoreType)</code> and replacing it with <code>KafkaStreams.store(StoreQueryParameters)</code>.</li>
+ <li>Added a new public api to access lag information for stores local to an instance with <code>KafkaStreams.allLocalStorePartitionLags()</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>