Как создать KStream со списком stati c записей для модульного тестирования

Question

Я пытаюсь написать модульные тесты для класса, использующего потоки Kafka, например:

KStream stream = streamBuilder.stream(topic)
stream.foreach((key, value) -> {
    // do some data manipulations and validations
});

Есть ли способ добавить для этого модульные тесты, создав KStream из stati c data, например, чтобы получить поток строк:

arrayList.stream();

Answer 1

Использование ToplogyTestDriver и TestInputTopi c позволяет добавлять записи stati c для тестирования топологии с помощью таких методов, как TestInputTopi c .pipeKeyValueList . Такое тестирование позволяет проверить топологию без дополнительных затрат на запуск физического брокера.

Дополнительную информацию можно найти в документации по тестированию Kafka Streams .

HTH, Bill