Kafka Streams in Action

List of Listings

Chapter 2. Kafka quickly

Listing 2.1. PurchaseKey composite key

Listing 2.2. PurchaseKeyPartitioner custom partitioner

Listing 2.3. SimpleProducer example

Listing 2.4. Manually setting the partition

Listing 2.5. ThreadedConsumerExample example

Chapter 3. Developing Kafka Streams

Listing 3.1. Defining the source for the stream

Listing 3.2. Mapping incoming text to uppercase

Listing 3.3. Creating a sink node

Listing 3.4. Hello World: the Yelling App

Listing 3.5. Building the source node and first processor

Listing 3.6. Second processor and a sink node that writes to Kafka

Listing 3.7. Third processor and a terminal node that writes to Kafka

Listing 3.8. Final processor

Listing 3.9. ZMart customer purchase KStream program

Listing 3.10. ...