Проверьте настройки повторных попыток издателя GCP в приложении Spring

Question

У меня есть приложение для весенней интеграции, которое прослушивает сообщения из топика Kafka c и публикует их в Google Cloud Topi c.

Издатель GCP создан с использованием DefaultPublisherFactory и имеет нижеприведенное ниже. повторите настройку

RetrySettings retrySettings = RetrySettings.newBuilder()
        .setInitialRetryDelay(Duration.ofSeconds(1))
        .setRetryDelayMultiplier(600)
        .setMaxRetryDelay(Duration.ofSeconds(2))
        .setTotalTimeout(Duration.ofSeconds(10))
        .setInitialRpcTimeout(Duration.ofSeconds(10))
        .setMaxRpcTimeout(Duration.ofSeconds(10))
        .build()

Приложение работает, и все работает, как ожидалось.

Но я не могу понять, как проверить вышеуказанные настройки повтора.

Поскольку приложение не выходит из строя - сценарий повтора не тестируется.

Я довольно новичок в интеграционном тестировании - я много гуглил - но не мог придумать - как создать или смоделировать сценарий повторения.

Любое руководство по выяснению этого было бы очень полезно.

Спасибо.

Answer 1

Служба поддержки Google Cloud здесь!

Как сказал DCTID, ваш код не легко тестируется, потому что он будет запускаться только в случае сбоя приложения. По этой причине я бы посоветовал вам просто подождать, пока это не произойдет - если это когда-нибудь произойдет.