kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka-site] branch asf-site updated: Minor: Updating upgrade docs for KIP-535 and KIP-562 (#267)
Date Wed, 10 Jun 2020 21:13:40 GMT
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 <navinder_brar@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 <matthias@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>


Mime
View raw message