В настоящее время я работаю над проектом, в котором у нас есть реализация kafka в архитектуре микросервиса. Удалось ли вам создать контрактные тестовые примеры для взаимодействия темы mS с kafka, используя pact-jvm?
Моя реализация заключается в том, что microservice1 публикует сообщение клиенту REST, который, в свою очередь, отправляет сообщение в тему Kafka. microservice2 использует метод GET для получения сообщений из темы Kafka.
Pact-JVM поддерживает Message Pacts, которые инкапсулируют сообщение, которое потребляется (в одну сторону) через некоторый механизм, обычно через очередь сообщений. Идея состоит в том, чтобы проверить, может ли потребительский код использовать сообщение с помощью потребительского теста, а затем убедиться, что провайдер генерирует соответствующее сообщение. Фактическая очередь сообщений не используется в тесте.
Первоначально он был разработан для применения контрактных тестов для микросервисов, взаимодействующих через очередь сообщений Kafka.
Тесты состоят из двух частей, как и тесты пакта запрос-ответ, за исключением того, что Потребитель читает сообщение во время теста пакта потребителя, и в случае успеха записывается файл пакта. Затем вызывается код провайдера для создания сообщения, которое сравнивается с тем, что находится в файле pact.
Соответствующие разделы документов Pact-JVM:
