Consuming and Producing Messages

In a Kafka Streams application, data processing is triggered by incoming messages consumed from one or more Kafka topics. In some applications, the stream processing ends with messages produced to one more topic. This happens automatically because our application is usually a part of a larger system where upstream applications are the producers of our incoming messages, and downstream applications are the consumers of our outbound messages.

However, verifying that the application we are building is working as expected during the different stages of implementation is an important aspect of our job as developers. Being able to manually trigger our Kafka Streams application on demand would make our work ...