Конкретная проблема, с которой приходится сталкиваться, заключается в имитации контекста, хранилищ состояний и оконных объектов, которые передаются в процесс функции.
Похоже, все примеры, например, здесь и здесь модульные тесты на уровне потока (например, mockStreams или использование EmbeddedKafkaCluster).
Если вы хотите протестировать реализацию одного процессора и вам нужно имитировать контекст, хранилища состояний и т. д., я бы просто использовал любые инструменты тестирования, которые вы обычно используете для имитации вещей (Mockito, CGLIB и т. д.).
Помимо объема вашего вопроса, существует также ProcessorTopologyTestDriver. Публикация на случай, если вы пропустили. Kafka Streams получает новые/улучшенные функции тестирования в следующая версия.
