Kafka Streams in Action

Chapter 8. Testing a Kafka Streams application

This chapter covers

• Testing a topology
• Testing individual processors and transformers
• Integration testing with an embedded Kafka cluster

So far, we’ve covered the essential building blocks for creating a Kafka Streams application. But there’s one crucial part of application development I’ve left out until now: how to test your application. One of the critical concepts we’ll focus on is placing your business logic in standalone classes that are entirely independent of a Kafka Streams application, because that makes your logic much more accessible to test. I expect you’re aware of the importance of testing, but we’ll review my top two reasons for why testing is just as necessary as the development ...