Skip to content

Commit

Permalink
FEAT : Modif d'une exception qui terminait le programme
Browse files Browse the repository at this point in the history
  • Loading branch information
pierre-maraval committed Nov 23, 2023
1 parent 1b1af39 commit 8f026e3
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions src/main/java/fr/abes/kbart2kafka/service/FileService.java
Original file line number Diff line number Diff line change
Expand Up @@ -91,16 +91,14 @@ private void executeMultiThread(File fichier, String kbartHeader) throws IOExcep
try {
log.debug("Message envoyé : {}", mapper.writeValueAsString(result.get().getProducerRecord().value()));
} catch (JsonProcessingException | InterruptedException | ExecutionException e) {
sendErrorToKafka("Erreur dans le chargement à la ligne " + finalLineCounter, e, kafkaHeader);
throw new RuntimeException(e);
e.printStackTrace();
}
});
} catch (JsonProcessingException e) {
sendErrorToKafka("erreur de mapping des données au chargement de la ligne " + finalLineCounter, e, kafkaHeader);
throw new RuntimeException(e);
}
});

}
}

Expand Down

0 comments on commit 8f026e3

Please sign in to comment.