List of Listings

Chapter 1. Introducing event streams

Listing 1.1. Application logging with Log4j

Listing 1.2. Web tracking with Universal Analytics

Chapter 2. The unified log

Listing 2.1. shopper_viewed_product.json

Chapter 3. Event stream processing with Apache Kafka

Listing 3.1. build.gradle

Listing 3.2. Consumer.java

Listing 3.3. IProducer.java

Listing 3.4. PassthruProducer.java

Listing 3.5. StreamApp.java

Listing 3.6. FullProducer.java

Listing 3.7. StreamApp.java

Chapter 4. Event stream processing with Amazon Kinesis

Listing 4.1. agent.py

Listing 4.2. monitor.py

Chapter 5. Stateful stream processing

Listing 5.1. nile-carts.properties

Listing 5.2. Event.java

Listing 5.3. AbandonedCartEvent.java

Listing 5.4. AbandonedCartsStreamTask.java

Chapter 6. Schemas

Listing 6.1. build.gradle

Listing 6.2. check.avsc

Listing 6.3. AvroParser.java

Listing 6.4. SchemaApp.java

Listing 6.5. self_describing.avsc

Chapter 7. Archiving events

Listing 7.1. secor.common.properties

Listing 7.2. secor.dev.properties

Listing 7.3. build.gradle

Listing 7.4. ShopperAnalysisJob.scala

Chapter 8. Railway-oriented processing

Listing 8.1. fail-fast.bash

Listing 8.2. HelloCalculator.java

Listing 8.3. HelloIncrementor.java

Listing 8.4. build.gradle