Я пытаюсь проверить метод обратного вызова Kafka onFailure:
@Override
public void onFailure(Throwable ex) {
logger.error("Failure while sending message in kafka.", ex);
}
My test case code using Mockito. I am setting exception in object of class SettableListenableFuture.
SettableListenableFuture<SendResult<String, DeserializationResult<EnvelopeExpanded<SpecificRecord>>>> future2 = new SettableListenableFuture<>();
future2.setException(new Exception("Could not publish to Kafka"));
Exception ex = new Exception("Could not publish to Kafka");
verify(logger, times(1)).error("Failure while sending message in kafka.", ex);
Я получаю эту ошибку
Argument(s) are different! Wanted:
logger.error(
"Failure while sending message in kafka.",
java.lang.Exception: Could not publish to Kafka
);
Actual invocation has different arguments:
logger.error(
"Failure while sending message in kafka.",
java.lang.Exception: Could not publish to Kafka
);
И требуемые, и фактические аргументы совпадают, но все равно выдает ошибку.Кто-нибудь может мне помочь с этим ??