我怎样才能转到“@Override public void onFailure(Throwable ex) { ... }”?
它总是“@Override public void onSuccess(SendResult
我要打印 log.error("无法发送消息=["+kafkaPgResponseDto.toString()+"],因为:" + ex.getMessage());
请帮忙...
ListenableFuture<SendResult<String, KafkaPgResponseDto>> future = pgResponseKafkaTemplate.send(kurlyTopicNamePgResponse, kafkaPgResponseDto);
future.addCallback(new ListenableFutureCallback<SendResult<String, KafkaPgResponseDto>>(){
@Override
public void onSuccess(SendResult<String, KafkaPgResponseDto> result) {
KafkaPgResponseDto kafkaPgResponseDto = result.getProducerRecord().value();
log.debug("Send message=["+kafkaPgResponseDto.toString()+"] with offset=["+result.getRecordMetadata().offset()+"]");
}
@Override
public void onFailure(Throwable ex) {
log.error("Unable to send message=["+kafkaPgResponseDto.toString()+"] due to : "+ex.getMessage());
kafkaTransactionService.failedProcessingKafkaHistorySave(orderNo, kurlyTopicNamePgResponse, gson.toJson(payload), ex.toString());
}
});
我相信真正的Kafka没有必要测试你的功能。考虑使用
MockProducer
注入该 KafkaTemplate
并模拟该 onFailure()
情况的错误:https://www.baeldung.com/kafka-mock Producer
当然有需要。认为您想要测试重试配置,例如请求超时和 ao 开启。