diff --git a/40/streams/developer-guide/dsl-api.html b/40/streams/developer-guide/dsl-api.html index 4de5389ac7..e2a6d2ff42 100644 --- a/40/streams/developer-guide/dsl-api.html +++ b/40/streams/developer-guide/dsl-api.html @@ -3462,10 +3462,10 @@
The Processor API now serves as a unified replacement for all these methods. It simplifies the API surface while maintaining support for both stateless and stateful operations.
-CAUTION: If you are using KStream.transformValues() and you have the "merge repartition topics"
+
CAUTION: If you are using KStream.transformValues() or KStream.flatTransformValues() and you have the "merge repartition topics"
optimization enabled, rewriting your program to KStream.processValues() might not be safe due to
KAFKA-19668. For this case, you should not upgrade
- to Kafka Streams 4.0.0 or 4.1.0, but use Kafka Streams 4.0.1 instead, which contains a fix.
+ to Kafka Streams 4.0.0 or 4.1.0, but use Kafka Streams 4.0.1 or 4.1.1 instead, which contain a fix.
Note, that the fix is not enabled by default for backward compatibility reasons, and you would need to
enable the fix by setting config __enable.process.processValue.fix__ = true and pass it
into StreamsBuilder() constructor.
Below, methods applyDiscountWithTransform and applyDiscountWithProcess show how you can
+ migrate from transform to process.
public class CumulativeDiscountsForALoyaltyProgramExample {
private static final double DISCOUNT_THRESHOLD = 100.0;
private static final String CUSTOMER_SPENDING_STORE = "customer-spending-store";
diff --git a/41/streams/developer-guide/dsl-api.html b/41/streams/developer-guide/dsl-api.html
index 4de5389ac7..e2a6d2ff42 100644
--- a/41/streams/developer-guide/dsl-api.html
+++ b/41/streams/developer-guide/dsl-api.html
@@ -3462,10 +3462,10 @@
The Processor API now serves as a unified replacement for all these methods. It simplifies the API surface
while maintaining support for both stateless and stateful operations.
- CAUTION: If you are using KStream.transformValues() and you have the "merge repartition topics"
+
CAUTION: If you are using KStream.transformValues() or KStream.flatTransformValues() and you have the "merge repartition topics"
optimization enabled, rewriting your program to KStream.processValues() might not be safe due to
KAFKA-19668. For this case, you should not upgrade
- to Kafka Streams 4.0.0 or 4.1.0, but use Kafka Streams 4.0.1 instead, which contains a fix.
+ to Kafka Streams 4.0.0 or 4.1.0, but use Kafka Streams 4.0.1 or 4.1.1 instead, which contain a fix.
Note, that the fix is not enabled by default for backward compatibility reasons, and you would need to
enable the fix by setting config __enable.process.processValue.fix__ = true and pass it
into StreamsBuilder() constructor.
@@ -3680,6 +3680,8 @@ Replacing Slang in Text Messag
}
}
Below, methods applyDiscountWithTransform and applyDiscountWithProcess show how you can
+ migrate from transform to process.
public class CumulativeDiscountsForALoyaltyProgramExample {
private static final double DISCOUNT_THRESHOLD = 100.0;
private static final String CUSTOMER_SPENDING_STORE = "customer-spending-store";