Unit test examples for Kafka Streams
Repository for the blog entry How to test Kafka-Streams
In this repository we have three different kafka-stream examples:
- Bank Balance: Extracted from udemy. Process all incoming transactions and accumulate them in a balance.
- Customer purchases dispatcher: Process all incoming purchases and dispatch to the specific customer topic informed in the purchase code received.
- Menu preparation: For each customer, the stream receives several recipes and this recipes must be grouped into a menu and sent by email to the customer. A single email should be received by each customer
For the above scenarios, we have unit and/or integration tests.
- Unit tests has been developed with kafka-streams-test-utils library.
- Integration tests has been developed with spring-kafka-test library.
- clone the repository
- mvn clean test