Kafka Broker and Streams Enhancements
Easy Kafka Streams Testing with TopologyTestDriver - KIP-470

Easy Kafka Streams Testing with TopologyTestDriver - KIP-470

12/17/2019 · Jukka Karvanen

What this post added

Introduces and demonstrates the usage of TestInputTopic and TestOutputTopic classes from KIP-470 for simplifying Kafka Streams testing with TopologyTestDriver. Provides examples using AssertJ for testing single records (value, key-value, record with timestamp, record with headers) and collections of records (value lists, key-value lists, record lists, key-value maps). Includes guidance on migrating to the new interface and references external testing resources.

Read the original post ↗