Kafka Streams : Example 1 straight through processing / How to test Kafka Streams

Introduction In this post we will look at some of the key objects we looked at last time, and we will also see what a typical Scala (though Kafkas libraries are mainly Java, I just prefer Scala) app looks like. It is not a complicated application, which is exactly what you want when you are starting to learn something. I have deliberately started simple, and we will expand our knowledge as we go Where is the code? The code will all be in this single repo : https://github.com/sachabarber/KafkaStreamsDemo What tools will I need to follow along As I am using Scala, if you really want to download and try the examples that will go with this series, you will need the following Scala 2.12 SBT Java 1.8 SDK A Scala IDE (I like the community edition of IntelliJ IDEA myself) A typical Kafka Streams application So last time we talked about a few common objects you might expect to see when working with KafkaStreams such as KStream KTable Global KTable State Store But we did not talk about what a typical app would look like.

✔ Read More...

I guess you came to this post by searching similar kind of issues in any of the search engine and hope that this resolved your problem. If you find this tips useful, just drop a line below and share the link to others and who knows they might find it useful too.

Stay tuned to my blog, twitter or facebook to read more articles, tutorials, news, tips & tricks on various technology fields. Also Subscribe to our Newsletter with your Email ID to keep you updated on latest posts. We will send newsletter to your registered email address. We will not share your email address to anybody as we respect privacy.

This article is related to

Kafka