Testing Kafka Streams Topologies
Learn how to write unit tests for Kafka Streams topologies using TopologyTestDriver.
We'll cover the following...
Every time we add or change the logic in our Kafka Streams topology, we should verify that our changes have the correct outcomes. This verification can be done by:
Starting a Kafka cluster
Running the entire application
Publishing input messages using the producer CLI
Reading the output message using the consumer CLI
While we should do this at least once or twice to verify all the parts of the system are playing correctly together, ...