Easy Kafka Streams Testing with TopologyTestDriver - KIP-470

This post introduces KIP-470, which enhances the TopologyTestDriver for Kafka Streams testing. It adds TestInputTopic and TestOutputTopic classes, simplifying the process of feeding records and reading output. The post demonstrates how to use these new classes with AssertJ for testing single records, collections of records, and validating keys, values, timestamps, and headers. It also discusses migrating existing tests and provides links to external resources for further learning.