This chapter covers
- Introducing the Kafka Streams API
- Building Hello World for Kafka Streams
- Exploring the ZMart Kafka Streams application in depth
- Splitting an incoming stream into multiple streams
In chapter 1, you learned about the Kafka Streams library. You learned about building a topology of processing nodes, or a graph that transforms data as it’s streaming into Kafka. In this chapter, you’ll learn how to create this processing topology with the Kafka Streams API.
The Kafka Streams API is what you’ll use to build Kafka Streams applications. You’ll learn how to assemble Kafka Streams applications; but, more important, you’ll gain a deeper understanding of how the components work together and how they can be used to achieve your stream-processing goals.
The Kafka Streams DSL is the high-level API that enables you to build Kafka Streams applications quickly. The high-level API is very well thought out, and there are methods to handle most stream-processing needs out of the box, so you can create a sophisticated stream-processing program without much effort. At the heart of the high-level API is the KStream object, which represents the streaming key/value pair records.