From 4b97e50eea977a2a9020e6ed49516a1904361f12 Mon Sep 17 00:00:00 2001 From: Navinder Pal Singh Brar Date: Wed, 27 May 2020 04:54:00 +0530 Subject: [PATCH] MINOR: Added doc for KIP-535 and updated it for KIP-562 (#8395) Reviewers: Boyang Chen , Vinoth Chandar , Matthias J. Sax --- docs/streams/upgrade-guide.html | 5 +++-- docs/upgrade.html | 5 ++++- 2 files changed, 7 insertions(+), 3 deletions(-) diff --git a/docs/streams/upgrade-guide.html b/docs/streams/upgrade-guide.html index 30b21e4e479..7d64cd3aab5 100644 --- a/docs/streams/upgrade-guide.html +++ b/docs/streams/upgrade-guide.html @@ -123,8 +123,9 @@

Deprecated KafkaStreams.store(String, QueryableStoreType) and replaced it with KafkaStreams.store(StoreQueryParameters) to allow querying - for specific partition and specific task type as per - KIP-562. + for a store with variety of parameters, including querying a specific task and stale stores, as per + KIP-562 and + KIP-535 respectively.

Streams API changes in 2.4.0

diff --git a/docs/upgrade.html b/docs/upgrade.html index 4c6f653999d..103fb99feaf 100644 --- a/docs/upgrade.html +++ b/docs/upgrade.html @@ -46,7 +46,10 @@ examples folder. Check out KIP-447 for the full details. -
  • Deprecated KafkaStreams.store(String, QueryableStoreType) and replaced it with KafkaStreams.store(StoreQueryParameters).
    • +
  • Added a new public api 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.
    • +
  • Provided support to query stale stores (for high availability) and the stores belonging to a specific partition by deprecating KafkaStreams.store(String, QueryableStoreType) and replacing it with KafkaStreams.store(StoreQueryParameters).
    • +
  • Added a new public api to access lag information for stores local to an instance with KafkaStreams.allLocalStorePartitionLags().
  • Scala 2.11 is no longer supported. See KIP-531 for details.