Kafka Streams Programming - WordCount Topology

Learn how to write the topology using the High-Level DSL for the WordCount application!
If you want to learn more: links.datacumulus.com/kafka-s...
Get the Kafka Streams for Data Processing course at a special price!
Don’t forget to subscribe to get more content about Apache Kafka and AWS!
I'm Stephane Maarek, a consultant and software developer, and I have a particular interest in everything related to Big Data, Cloud and API. I sat on the 2019 Program Committee organizing the Kafka Summit. I'm also an AWS Certified Solutions Architect, Developer, SysOps Administrator, and DevOps Engineer.
My other courses are available here: courses.datacumulus.com/
Follow me on social media:
LinkedIn - / stephanemaarek
Twitter - / stephanemaarek
Medium - / stephane.maarek

[@StephaneMaarek]

If you want to learn more, check out my Apache Kafka Series - Kafka Streams for Data Processing course : links.datacumulus.com/kafka-streams-coupon

[@JohnuCelestine]

Excellent video, on point. Thanks for making this!

[@arvindsingh32]

Thank you so much for this video

[@girishkumar518]

Thank you for your time

[@jean-boscomudereva5887]

Excellent video! C'est super, on en veut plus!

[@StephaneMaarek]

==> kafka-tutorials.com

[@filat239]

very clear!

[@SyamKumarVoleti]

Beautifully composed session. Come up with more sessions please. I have already subscribed your channel :)

[@StephaneMaarek]

==> kafka-tutorials.com

[@architasundaray8206]

where can I see the final result? Is there a way to print on console or write it to a textfile?

[@adrianjason13]

Impressive tutorial. Very useful. Btw, do you have this for Spring Boot using Spring cloud stream?

[@andres99f]

thanks Stephane for the tutorial. Based on your example, I want to get two topics, mix them together and store them result in a store. Why a store?, because I want to have the result stored permanently. The question is, how can I to create a store and how can I to check from a microservice, if the store exist before try to create it. This to avoid to rewrite it, and to have access to this store each time I start the microservice.
thanks in advance for any advice.

[@ankitsoni13]

is ConsumerGroupName and multiple consumer concept also applicable in KafkaStreams?

[@rahulkmr710]

Hi Sir, please upload spring boot and microservices topics with programming examples videos

[@SpiritOfIndiaaa]

#StephaneMaarek , thanks how to handle a json message input for TumblingWindow on group by i.e customer function for groupBy logic.

[@sapientum8]

OK