Kafka stream api - как протестировать обработку со встроенным kafka

Question

Я бы хотел проверить свой процессор со встроенной кафкой. Это вообще возможно?

Когда я запускаю приложение локально с Kafka & ZK, тогда оно работает отлично - мой слушатель примера получает сообщение так же, как процессор (отлично, оба слушают одну и ту же тему), но когда я тестирую его со встроенной kafka, тогда аннотируется только метод с @KafkaListener получает сообщение, но процессор ничего не получает.

Я хотел бы отправить сообщение в тему процессора, а затем проверить, отправил ли он результат в другую тему.

Есть ли решение для такого варианта использования?

Answer 1

Рекомендуется проверить ваш код, используя TopologyTestDriver: https://kafka.apache.org/11/documentation/streams/developer-guide/testing.html

Вы также можете использовать KafkaEmbedded, а может лучше EmbeddedKafkaCluster. Для примера, посмотрите интеграционные тесты Kafka Streams: https://github.com/apache/kafka/tree/trunk/streams/src/test/java/org/apache/kafka/streams/integration