Для чего нужен Streams DSL?

Kafka Streams DSL — это высокоуровневый API для операций потоковой обработки данных. Он позволяет описывать логику фильтрации, преобразования, агрегации и объединения потоков данных, абстрагируя низкоуровневые детали обработки.

DSL оперирует абстракциями KStream (поток событий) и KTable (changelog-таблица), что позволяет строить сложные топологии обработки декларативно.

На собеседовании: покажите понимание разницы между KStream и KTable. KStream — это неограниченный поток событий (каждая запись — факт). KTable — это материализованное представление последнего значения по ключу (как таблица в БД).