ZMartKafkaStreamsAddStateApp.java does not process Purchase records

[ahmedha]

ZMartKafkaStreamsAddStateApp app (in Chapter 4 directory) does not work with latest version of Kafka Streams. I pretty much copied the code in github - https://github.com/bbejeck/kafka-streams-in-action/blob/master/src/main/java/bbejeck/chapter_4/ZMartKafkaStreamsAddStateApp.java . When I run the code as is, no data is flowing through the topology. I verified that mock data is being generated, as I can see the offset in the input topic - transactions go up. However, nothing in the output topics, and nothing is printed to console.

However, when I comment line 81-88 (https://github.com/bbejeck/kafka-streams-in-action/blob/master/src/main/java/bbejeck/chapter_4/ZMartKafkaStreamsAddStateApp.java#L81-L88), basically avoid creating the "through()" processor node, and the code works. After commending, I see data being generated to the "patterns" topics, and output generate in console.

If there is no plans to address/fix the issue, would appreciate any pointers so I can get the code working on my setup. Thank you.