@@ -3462,10 +3462,11 @@ <h3>
34623462 < p > The Processor API now serves as a unified replacement for all these methods. It simplifies the API surface
34633463 while maintaining support for both stateless and stateful operations.</ p >
34643464
3465- < p > < b > CAUTION:</ b > If you are using < code > KStream . transformValues ( ) < / c o d e > a n d y o u h a v e t h e " m e r g e r e p a r t i t i o n t o p i c s "
3465+ < p > < b > CAUTION:</ b > If you are using < code > KStream . transformValues ( ) < / c o d e > o r < c o d e > K S t r e a m .f l a t T r a n s f o r m V a l u e s ( ) < / code>
3466+ and you have the "merge repartition topics"
34663467 optimization enabled , rewriting your program to < code > KStream . processValues ( ) < / c o d e > m i g h t n o t b e s a f e d u e t o
34673468 < a href = "https://issues.apache.org/jira/browse/KAFKA-19668" > KAFKA-19668</ a > . For this case , you should not upgrade
3468- to Kafka Streams 4.0 .0 or 4.1 .0 , but use Kafka Streams 4.0 .1 instead , which contains a fix .
3469+ 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 .
34693470 Note , that the fix is not enabled by default for backward compatibility reasons , and you would need to
34703471 enable the fix by setting config < code > __enable . process . processValue . fix__ = true < / c o d e > a n d p a s s i t
34713472 into < code > StreamsBuilder ( ) < / c o d e > c o n s t r u c t o r .< / p>
@@ -3680,6 +3681,8 @@ <h5 id="replacing-slang-in-text-messages-removal">Replacing Slang in Text Messag
36803681 }
36813682} </ code > </ pre >
36823683 < h5 id = "cumulative-discounts-for-a-loyalty-program-removal" > Cumulative Discounts for a Loyalty Program < / h 5 >
3684+ < p > Below, methods < code > applyDiscountWithTransform</ code > and < code > applyDiscountWithProcess</ code > show how you can
3685+ migrate from < code > transform</ code > to < code > process</ code > .</ p >
36833686 < pre class = "line-numbers" > < code class = "language-java" > public class CumulativeDiscountsForALoyaltyProgramExample {
36843687 private static final double DISCOUNT_THRESHOLD = 100.0 ;
36853688 private static final String CUSTOMER_SPENDING_STORE = & quot ; customer - spending - store & quot ; ;
0 commit comments